Если старые данные действительно не нужны этой группе, можно перенести её смещения на нужную позицию, например конец каждой партиции.
В Kafka topic накопилось 5 миллиардов ненужных сообщений. Как их пропустить/не читать?
Если старые данные действительно не нужны этой группе, можно перенести её смещения на нужную позицию, например конец каждой партиции.
Короткий ответ
Что ответить на собеседовании
Подробный разбор
Ответ с пояснениями
Если старые данные действительно не нужны этой группе, можно перенести её смещения на нужную позицию, например конец каждой партиции.
Сначала остановите потребителей и проверьте план и последствия пропуска. Изменение смещений не удаляет сообщения из топика и не влияет автоматически на другие группы.