Как обеспечить, чтобы потребитель kafka всегда использовал последние зафиксированные смещения от брокера, а не локально, когда auto.commit.enabled = False - PullRequest
0 голосов
/ 11 июня 2019

Я установил enable.auto.commit = Ложь

Теперь я читаю некоторые данные из Кафки и почему-то не могу их обработать. Итак, я не фиксирую смещение. Теперь я снова опрашиваю и ожидаю те же данные, но я получаю новые данные, а не от того места, где они были получены в прошлый раз.

Я проверил, что для опроса используется локальное кэшированное смещение. Как сделать так, чтобы при опросе не использовалось локальное кэшированное смещение, иначе сама идея отключения автоматической фиксации становится бесполезной?

...