Kafka: смещение выборки вне диапазона для раздела. Как избежать потери данных? - PullRequest
1 голос
/ 25 мая 2020
Fetcher INFO : Fetch offset .... is out of range for partition ..., resetting offset 

Пытаюсь понять, что происходит, когда это происходит. Если смещение, которое мы пытаемся прочитать, отсутствует (я предполагаю, что из-за kafka G C 'ed offet) и auto.offset.reset = latest пропускаем ли мы данные до последнего смещения?

Какая безопасная конфигурация чтобы избежать потери данных?

...