Кафка — Что произойдет, если сообщение, которое должен прочитать подписавшийся потребитель, будет удалено?

#apache-kafka

Вопрос:

Интересно, что бы произошло в следующей ситуации.

  1. Значение смещения, которое должен прочитать подписавшийся потребитель, равно 7.
  2. Остановите потребителя.
  3. Поступило 20 новых сообщений.
  4. Сообщения со смещением менее 10 удаляются.
  5. Запустите потребителя.

Ответ №1:

Потребитель будет стремиться вернуться к auto.offset.reset ценности