Кафка соединяется с приращением режима - PullRequest
0 голосов
/ 28 сентября 2018

У нас есть столбец id для увеличения столбца в kafka-connect.Мне было интересно, если я просто обновлю столбец id на другое уникальное значение идентификатора.Включает ли это инкрементный режим kafka-connect для извлечения данных из таблицы?

1 Ответ

0 голосов
/ 01 октября 2018

kafka-connect периодически извлекает данные из источника.Интервал времени по умолчанию составляет 5000 миллисекунд, и вы можете изменить его с помощью свойства poll.interval.ms.Если новое значение обновленного id больше, чем последнее извлеченное последнее id, строка будет извлечена соединителем при следующем запланированном запросе.

...