Kafka 源 JDBC 连接器 - 微批处理
Kafka Source JDBC Connector - Micro-batching
作为 POC 的一部分，我有一个 Kafka JDBC 源连接器任务，它基本上读取 MySQL table 的所有内容并将记录转储到 Kafka 主题中。
table 仅包含 2 条记录，我的 batch.max.rows 值为 2。当任务以“批量”模式运行时，我在 kafka 主题中看到 2 条单独的 JSON 记录.我将如何配置连接器以插入 1 JSON 记录，其中包含包含这 2 条记录的 JSON 数组。最终没有。发布到 kafka 主题的消息数量为 1 而不是 2。
每个数据库行都将成为唯一的 Kafka 记录。
如果你想加入/window条记录，那么你会使用流处理器
作为 POC 的一部分，我有一个 Kafka JDBC 源连接器任务，它基本上读取 MySQL table 的所有内容并将记录转储到 Kafka 主题中。
table 仅包含 2 条记录，我的 batch.max.rows 值为 2。当任务以“批量”模式运行时，我在 kafka 主题中看到 2 条单独的 JSON 记录.我将如何配置连接器以插入 1 JSON 记录，其中包含包含这 2 条记录的 JSON 数组。最终没有。发布到 kafka 主题的消息数量为 1 而不是 2。
每个数据库行都将成为唯一的 Kafka 记录。
如果你想加入/window条记录，那么你会使用流处理器