------------恢復內容開始------------
最近測試環境的kafkaTopic太多太亂,大部分測試用的topic已經沒有用了,就想着刪掉。查閱了網上博客資料之后進行了操作。
1.有說在kafka的server配置文件中加上delete.topic.enable=true然后使用命令./bin/kafka-topics --delete --zookeeper 【zookeeper server:port】 --topic 【topic name】刪除的。經過驗證可行。
2:另一種就是不用在server配置文件添加參數,直接通過zookeeper來刪除。首先在zk的bin目錄下執行./zkCli.sh命令,然后執行ls /admin/delete_topics查看zk下的所有topic,然后執行deleteall /brokers/topics/【topic name】來刪除topic。
上面兩種命令親測有效,在刪除前需要把topic相關的生產者和消費者全部都停掉,不然會導致刪除不成功,