Kafka Connect JDBC 接收器提交
Kafka Connect JDBC Sink Commits
我找不到关于 JDBC 目标的 Kafka Connect JDBC Sink 的提交策略或参数。
它是每 N 行提交还是在达到 batch.size 时提交？ N 行是什么？批量大小或何时完成才有意义。
当 Kafka Connect worker 是 运行 接收器任务时，它 will consume messages from the topic partition(s) assigned to the task: once partitions have been opened for writing, Connect will begin forwarding records from Kafka using the put(Collection) API。
JDBC 接收器连接器写入通过 put(Collection) method using a transaction 传递的每批消息（其大小可以通过连接器的消费者设置来控制）。
我找不到关于 JDBC 目标的 Kafka Connect JDBC Sink 的提交策略或参数。
它是每 N 行提交还是在达到 batch.size 时提交？ N 行是什么？批量大小或何时完成才有意义。
当 Kafka Connect worker 是 运行 接收器任务时，它 will consume messages from the topic partition(s) assigned to the task: once partitions have been opened for writing, Connect will begin forwarding records from Kafka using the put(Collection) API。
JDBC 接收器连接器写入通过 put(Collection) method using a transaction 传递的每批消息（其大小可以通过连接器的消费者设置来控制）。