В Kafka topic накопилось 5 миллиардов ненужных сообщений. Как их пропустить/не читать?

Если старые данные действительно не нужны этой группе, можно перенести её смещения на нужную позицию, например конец каждой партиции.

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

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

Если старые данные действительно не нужны этой группе, можно перенести её смещения на нужную позицию, например конец каждой партиции.

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

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

Если старые данные действительно не нужны этой группе, можно перенести её смещения на нужную позицию, например конец каждой партиции.

Сначала остановите потребителей и проверьте план и последствия пропуска. Изменение смещений не удаляет сообщения из топика и не влияет автоматически на другие группы.

Практика в реальном времени

Подготовьтесь к следующему собеседованию

Interview Boost учитывает вакансию, резюме и технологии и помогает сформулировать ответ прямо во время интервью.

Начать подготовку