Как удалить тему кафки из кластерной версии: 0.10.2.1

Question

Я не могу удалить тему кафки, она помечена для удаления, но никогда не удаляется. Я запускаю кластер кафки с кластером zookeeper.

версия kafka: 0.10.2.1

Может кто-нибудь мне помочь, со списком шагов, которые нужно выполнить, чтобы удалить тему в кластер kafka .

Прошел через различные запросы в стеке потока, но не смог найти действительный работоспособный ответ.

Answer 1

Вы должны были включить его свойство в config до запуска сервера kafka; по умолчанию он отключен. Чтобы включить свойство удаления, сначала остановите сервер kafka, а затем откройте server.properties в файле конфигурации а затем раскомментируйте #delete.topic.enable=true или добавьте
delete.topic.enable=true
в конце файла.

Теперь вы можете запустить сервер kafka, а затем удалить любую тему, которую хотите, через:
bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic YOUR_TOPIC_NAME.

Answer 2

Вы можете использовать Kafka Tool

Ссылка для скачивания здесь

Затем подключитесь к вашему kafka server.

После этого вы можете увидеть доступные темы на этом сервере. Оттуда вы можете выбрать и удалить темы.