После обнаружения сбоя partitions упавшего consumer будут переназначены. Если offset обработки не был подтверждён, новый consumer начнёт с последнего committed offset и может повторно получить сообщение.
Если pod падает посередине обработки Kafka-сообщения, автокоммит отключён, что произойдёт с очередью, оставшимися pod и сообщением?
После обнаружения сбоя partitions упавшего consumer будут переназначены. Если offset обработки не был подтверждён, новый consumer начнёт с последнего committed offset и может повторно получить сообщение.
Короткий ответ
Что ответить на собеседовании
Подробный разбор
Ответ с пояснениями
После обнаружения сбоя partitions упавшего consumer будут переназначены. Если offset обработки не был подтверждён, новый consumer начнёт с последнего committed offset и может повторно получить сообщение.
Записи не исчезают из Kafka при падении pod. Остальные consumers обычно продолжают работу, но rebalance может временно менять назначения; точное поведение зависит от протокола. Если внешний эффект уже произошёл до падения, повтор создаст дубль без идемпотентности. Отключение auto commit само по себе не задаёт правильный момент ручного commit.