#apache-kafka
#apache-kafka
Вопрос:
Я хочу удалить все записи в разделе с сжатым журналом, не отключая кластер kafka и не удаляя тему. Погуглил совсем немного, но не смог найти способ удалить все записи из раздела с сжатым журналом.
Спасибо, Ахмед.
Комментарии:
1. Вы могли бы установить retention.ms до 1, подождите немного и верните ему исходное значение.
2. Это работает только для «обычных» тем, а не для разделов с сжатым журналом.
3. Попробуйте отправить сообщения tombstone в эту тему
4. @IskuskovAlexander Я хочу «вслепую» удалить все записи в разделе «сжатый журнал». (Аналогично тому, как работает скрипт «delete_records»).
Ответ №1:
Вы можете динамически изменять ‘cleanup.policy’ с помощью команды kafka-topics. Измените его на ‘удалить’, установите ‘retention.ms ‘ до 1, подождите, пока произойдет удаление, в течение 5 минут. Затем переключитесь обратно на политику ‘compact’. https://docs.confluent.io/current/installation/configuration/topic-configs.html#cleanup.policy