jdbc sink配置选项batch.size

fquxozlt  于 2021-06-05  发布在  Kafka
关注(0)|答案(1)|浏览(615)

从https://docs.confluent.io/3.1.1/connect/connect-jdbc/docs/sink_config_options.html#jdbc-接收器配置选项

Specifies how many records to attempt to batch together for insertion into the destination table, when possible.

Type: int
Default: 3000
Valid Values: [0,…]
Importance: medium

所以,这是来自汇合点。
重要性为中等,默认值为3000。如果我想Kafka每30秒改变一次,即使有说,只有27Kafka信息的主题?什么是默认设置,在该设置中,处理以每次经过的时间为基础进行?我们都知道这是适合的,因为我们可以运行许多示例,只从中传递1条记录,比如mysql到sqlserver,但是我找不到基于时间的处理的参数值。我能影响它吗?
https://github.com/confluentinc/kafka-connect-jdbc/issues/290 我也注意到了这一点。那里有些有趣的东西。

yfjy0ee7

yfjy0ee71#

我觉得你应该把重点放在“可能的时候”这个词上 consumer.max.poll.records 总是能从Kafka那里拿到那么多唱片。一旦轮询完成,jdbc接收器将根据需要构建尽可能多的批,直到在中调用下一个使用者轮询 consumer.max.poll.interval.ms

相关问题