: 1000, "table.whitelist": "college" } }' \ ...
} 如果我创建一个简单的JDBC接收器来将数据放到另一个mysql DB中，事情就完全没有问题了： curl -X POST -H "Content-Type:但是，如果我创建一个使用插入模式<e
浏览 5提问于2020-08-26得票数 1
回答已采纳
2回答
在客户关系管理中，accound_id GUID字段是主键。我希望能够在CRM中查找它，如果它存在或生成一个新的。
浏览 2提问于2020-09-14得票数 0
我正在设计一个MySQL -> Debezium -> Kafka -> Flink -> Kafka -> Kafka Connect JDBC -> MySQL。下面是我在Flink上写的示例消息(我也尝试过使用Kafka控制台生产者) { "type": "struct", {JsonConverter.java:338) 我已经调试过了，方法中的public
浏览 70提问于2019-02-27得票数 0
回答已采纳
1回答
null","int"],"default": null}]}' \然后我从卡夫卡那里得到了这个接收器属性的数据", "name": "jdbc-oracle" "tasks&
浏览 2提问于2020-04-14得票数 0
回答已采纳
我的接收器配置文件包含以下配置-"tasks.max": "1",
"topics": "DELETESRC我可以使用upsert使用键，但不能在JDBC接收器中使用delete模式。我将主题DELETESRC配置为cleanup.policy=compact
浏览 1提问于2020-04-15得票数 1
回答已采纳
我正在尝试使用JDBC接收器连接器读取2个kafka主题，并将其插入到我手动创建的两个Oracle表中。每个表都有一个主键，我想在upsert模式下使用它。如果我只使用pk.fields中的一个主题和一个字段，连接器就可以正常工作，但是如果我在pk.fields中输入多个列(每个表中输入一个列)，它就无法识别模式。我有遗漏什么东西吗请提出建议。name=oracle_sink_prod
浏览 1提问于2017-09-12得票数 3
回答已采纳
然后使用kafka-connect将该文件还原到另一个主题。 }, { "id": 0,
"worker_id&qu
浏览 1提问于2019-02-08得票数 1
1回答
我已经使用kafka- s3 s3接收器连接器将一些avro消息从主题上传到亚马逊连接桶(假设s3-bucket )。我向主题写入了5，并在我的存储桶中看到了一个带有路径的s3对象 /topics/my.topic/partition=0/my.topic+0+0000000000.avro 现在，我想将这些存储的消息放到另一个空主题中(在docker容器中运行)生成的日志时，它看起来很好，没有错误，它正确地识别了我的存储桶，并且其中的目录路径被指定为要监视的 /topics/my
浏览 52提问于2020-07-05得票数 2
我使用Kafka和Kafka将MySQL数据库复制到MySQL，使用源连接器和汇流JDBC接收器连接器。"auto.create“设置为true，接收器连接器确实创建了表，但有些数据类型不匹配。在SQL Sever中，我有 id INTEGER IDENTITY(1001,1) NOT NULL PRIMARY KEY, start_date DATE,
浏览 15提问于2022-03-04得票数 0
之所以需要这样做，是因为我正在使用JDBC Source和Sink连接器在两个数据库之间传输数据。在水槽那端，我做的是upserts。因此，我需要以下字段： "insert.mode": "upsert", "pk.fields":"TABLE_ID", 这可以很好地工作，但是它将我绑定
浏览 24提问于2020-06-09得票数 2
回答已采纳
我的接收器属性: "name": "jdbc-oracle", "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector", "plugin.path": "/home
浏览 2提问于2020-04-13得票数 2
回答已采纳
它说：INSERT INTO pageviews_per_region user_region, COUNT(DISTINCTuser_id)GROUP BY user_region;
使
浏览 0提问于2021-06-09得票数 0
回答已采纳
例如，我在DB2中有一个名为ACTION的表，它也存在于具有相同列的Postgres中，唯一的区别是DB2的大写ACTION和Postgres的小写action。下面是一个可以工作的接收器文件： "name": "jdbc_sink_pg_action", "_comment": "The JDBC connectortable.name.format": &quo
浏览 0提问于2020-06-05得票数 3
回答已采纳
2回答
我对这个拱门的jdbc接收器有个问题。org.apache.kafka.connect.errors.RetriableException: java.sql.SQLException: java.sql.BatchUpdateException:批处理条目0插入"customers“("id")值(1)在冲突("id")上，更新集被中止:错误:输入connect_1的结尾处的语法错误
位置: 77调用getNextException查看批处理中的其他错误
浏览 2提问于2019-04-30得票数 2
)我将把连接器的详细信息放在下面(在码头容器中运行，为了清晰起见，删除连接字符串)： "name": "jdbc-conn", "
浏览 16提问于2022-04-10得票数 1
回答已采纳
源CSV用户文件将包含已经在D365表/实体中的用户和其他不存在的用户。
现有的D365用户表(字段的子集，只是为了说明)
更新的D365表，从源csv中添加了两个新记录
据我所见，Azure Data中有两种可能的解决方案
配置D365接收器来完成它例如，配置接收器以忽略与某一列匹配的记录？是否可以以某种方式配置接收器以实现这一点？我已经研究过这两种方法，但一直在</
浏览 4提问于2022-06-29得票数 0
回答已采纳
database.history.kafka.bootstrap.servers": "kafka:9092", } "auto.evolve": "true",
"delete.enabled"
浏览 39提问于2020-10-16得票数 1
回答已采纳
1回答
我正在尝试使用kafka-connect从两个表中获取行。我是这样配置connect-file-source.properties的connector.class=io.confluent.connect.jdbc.JdbcSourceConnectororg.apache.kafka.connect.json.JsonConverter
#value.converter.schema.registry.url=http://localhost:8
浏览 1提问于2020-09-29得票数 0
在Azure Data管道中，我使用的是复制数据操作。
当我运行它时，我得到一个错误，我不能在ID中插入null。我尝试执行一个完整的插入，它没有ID就能工作，但是当我更改为Upsert时，它会失败。这个问题也被提交给了微软帮助
浏览 9提问于2022-06-27得票数 0
我在forEach循环中使用findOneAndUpdate来创建/更新多个条目。是否应该不填充该阵列？ Name: software { },
{upsert_id
浏览 0提问于2013-06-06得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
