问Kafka源JDBC连接器-微批处理
EN

Stack Overflow用户

提问于 2021-01-06 21:14:22

回答 1查看 117关注 0票数 1

作为POC的一部分，我有一个任务，它基本上读取MySQL表的所有内容，并将记录转储到一个Kafka主题中。

该表仅包含2条记录&我的batch.max.rows值为2。当任务以"bulk“模式运行时，我在kafka主题中看到了2条单独的JSON记录。如何配置连接器以插入包含这2条记录的JSON数组的1条JSON记录。最终没有。向卡夫卡主题发布的信息为1而不是2。

回答已采纳

发布于 2021-01-07 19:34:02

每个数据库行都将成为唯一的Kafka记录。

如果您想要加入/窗口记录，那么您将使用流处理器

票数 2

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/65603462

复制

相似问题

问Kafka源JDBC连接器-微批处理EN