从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 我也注意到了这一点。那里有些有趣的东西。
1条答案
按热度按时间yfjy0ee71#
我觉得你应该把重点放在“可能的时候”这个词上
consumer.max.poll.records
总是能从Kafka那里拿到那么多唱片。一旦轮询完成,jdbc接收器将根据需要构建尽可能多的批,直到在中调用下一个使用者轮询consumer.max.poll.interval.ms