Если pod падает посередине обработки Kafka-сообщения, автокоммит отключён, что произойдёт с очередью, оставшимися pod и сообщением?

После обнаружения сбоя partitions упавшего consumer будут переназначены. Если offset обработки не был подтверждён, новый consumer начнёт с последнего committed offset и может повторно получить сообщение.

Короткий ответ

Что ответить на собеседовании

После обнаружения сбоя partitions упавшего consumer будут переназначены. Если offset обработки не был подтверждён, новый consumer начнёт с последнего committed offset и может повторно получить сообщение.

Подробный разбор

Ответ с пояснениями

После обнаружения сбоя partitions упавшего consumer будут переназначены. Если offset обработки не был подтверждён, новый consumer начнёт с последнего committed offset и может повторно получить сообщение.

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

ИИ-помощник для собеседований

Хочешь уверенно проходить собеседования?

Попробуй ИИ-помощник для собеседований: слышит вас и собеседника, анализирует экран, подсказывает ответы в реальном времени, работает без VPN и не попадает в захват экрана.

Подробнее