卡夫卡以递增模式连接

Question

我们有一个列id，用于在kafka-connect中递增列。 我想知道如果我只是将id列更新为另一个唯一 id 值。这是否会触发 kafka-connect 递增模式以从表中提取数据？

Answer 1

kafka-connect定期从源中提取数据。默认时间间隔为 5000 毫秒，您可以使用poll.interval.ms属性进行更改。如果更新id的新值大于最近拉取的最后一个id，则连接器将在下一个计划查询时获取该行。