есть кластер из 3-х брокеров, и периодически причинении топика происходит отскок оффсета назад (мониторю через committed offset в librdkafka)
У меня есть подозрение что это как-то может быть связано с ребвлансировкой, но по логами Кафки проверить не могу так как кластер не в моей зоне обслуживания
вызывается исключение offset_out_of_range скорее всего, что триггерит auto.offset.reset, который равен либо latest, либо earliest, либо none. если вы про то, что консьюмер группа начинает обрабатывать топик сначала
да, установлен `auto.offset.reset: earliest`да, по консьюмер группе я вижу скачок оффсета назад (возможно он дейстивтелно был не закомичен) а чем такое лечить не подскажите?
Обсуждают сегодня