Kafka Connect JDBC Sink Commits



我找不到 Kafka Connect JDBC Sink 在该 JDBC 目标方面的提交策略或参数。

它是每N行提交一次还是在到达batch.size时提交?那N行是什么?批量大小或完成时间是有意义的。

当 Kafka Connect 工作线程运行接收器任务时,它将使用来自分配给该任务的主题分区的消息:一旦分区被打开进行写入,Connect 将开始使用 put(Collection( API 从 Kafka 转发记录。

JDBC 接收器连接器使用事务(可以通过连接器的使用者设置控制其大小(写入通过 put(Collection( 方法传递的每批消息。

最新更新