Что происходит с сообщением в Kafka после того, как его прочитал Consumer?

В Apache Kafka сообщение после того, как его прочитал Consumer, не удаляется из топика.

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

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

В Apache Kafka сообщение после того, как его прочитал Consumer, не удаляется из топика. Kafka хранит сообщения в течение заданного времени (retention period) или до достижения определённого размера лога, независимо от того, были ли они прочитаны.

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

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

В Apache Kafka сообщение после того, как его прочитал Consumer, не удаляется из топика. Kafka хранит сообщения в течение заданного времени (retention period) или до достижения определённого размера лога, независимо от того, были ли они прочитаны.

Consumer отслеживает своё положение в топике с помощью смещений (offsets). После чтения сообщения Consumer может зафиксировать (commit) offset, чтобы указать, что это сообщение обработано. Это позволяет при перезапуске продолжить чтение с нужного места.

Таким образом, сообщение остаётся в Kafka до истечения срока хранения, а Consumer самостоятельно управляет, какие сообщения он уже прочитал и обработал.

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

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

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

Подробнее