Java kafka springbatch не читает сообщения с последнего принятого смещения, работает каждые 24 часа - PullRequest
0 голосов
/ 28 февраля 2020

Мне нужно читать сообщения от kafka и генерировать файл каждые 24 часа, для этого я написал springboot java пакет, используя KafkaItemReader api , который читает сообщения и генерирует файл. Но когда пакетный запуск в следующий раз снова считывает сообщения с самого раннего смещения, если установлено свойство gltransaction.reset=latest, он не читает никаких сообщений. Как сделать пакетное чтение из последнего смещения коммита?

...