Да. Пока сообщение не удалено по retention, consumer может вернуться к старому offset и обработать его снова.
🔴 Это особенно полезно, если в обработчике обнаружили баг:
исправили код → сдвинули offset назад → переиграли сообщения
Например, для consumer group можно сбросить offset через kafka-consumer-groups.
💡 Важно: offset хранится для consumer group, поэтому сброс влияет на чтение этой группой.
Kafka в этом плане отличается от классической очереди: прочитанное сообщение не исчезает сразу — его можно переиграть.
📍 Навигация: Вакансии • Задачи • Собесы
🐸 Библиотека Go-разработчика