Очистка сообщений в топике Apache Kafka

Для удаления данных в топике Apache Kafka необходимо выполнить следующие команды:

уменьшить время жизни сообщений в топике:

kafka-topics.sh --zookeeper srv1:2181,srv2:2181,srv3:2181 --alter --topic tmpQueue --config retention.ms=5000

дождаться автоматической очистки очереди сообщений в топике (5 минут) и проверить очередь:

kafka-console-consumer.sh ---zookeeper srv1:2181,srv2:2181,srv3:2181 --topic tmpQueue --from-beginning

восстановить конфигурацию:

kafka-topics.sh --zookeeper srv1:2181,srv2:2181,srv3:2181 --alter --topic tmpQueue --delete-config retention.ms
Back