前言：

刪除kafka topic及其數據，嚴格來說并不是很難的操作。但是，往往給kafka 使用者帶來諸多問題。項目組之前接觸過多個開發者，發現都會偶然出現無法徹底刪除kafka的情況。本文總結多個刪除kafka topic的應用場景，總結一套刪除kafka topic的標準操作方法。

step1：

如果需要被刪除topic 此時正在被程序 produce和consume，則這些生產和消費程序需要停止。

因為如果有程序正在生產或者消費該topic，則該topic的offset信息一致會在broker更新。調用kafka delete命令則無法刪除該topic。

同時，需要設置 auto.create.topics.enable = false，默認設置為true。如果設置為true，則produce或者fetch 不存在的topic也會自動創建這個topic。這樣會給刪除topic帶來很多意向不到的問題。

所以，這一步很重要，必須設置auto.create.topics.enable = false，并認真把生產和消費程序徹底全部停止。

step2：

server.properties?設置 delete.topic.enable=true

如果沒有設置 delete.topic.enable=true，則調用kafka 的delete命令無法真正將topic刪除，而是顯示（marked for deletion）

step3：

調用命令刪除topic：

./bin/kafka-topics --delete --zookeeper 【zookeeper server:port】 --topic 【topic name】

step4：

刪除kafka存儲目錄（server.properties文件log.dirs配置，默認為"/data/kafka-logs"）相關topic的數據目錄。

注意：如果kafka 有多個 broker，且每個broker 配置了多個數據盤（比如 /data/kafka-logs,/data1/kafka-logs ...），且topic也有多個分區和replica，則需要對所有broker的所有數據盤進行掃描，刪除該topic的所有分區數據。

?

一般而言，經過上面4步就可以正常刪除掉topic和topic的數據。但是，如果經過上面四步，還是無法正常刪除topic，則需要對kafka在zookeeer的存儲信息進行刪除。具體操作如下：

（注意：以下步驟里面，kafka在zk里面的節點信息是采用默認值，如果你的系統修改過kafka在zk里面的節點信息，則需要根據系統的實際情況找到準確位置進行操作）

step5：

找一臺部署了zk的服務器，使用命令：

bin/zkCli.sh -server 【zookeeper server:port】

登錄到zk shell，然后找到topic所在的目錄：ls /brokers/topics，找到要刪除的topic，然后執行命令：

rmr /brokers/topics/【topic name】

即可，此時topic被徹底刪除。

如果topic 是被標記為 marked for deletion，則通過命令 ls /admin/delete_topics，找到要刪除的topic，然后執行命令：

rmr /admin/delete_topics/【topic name】

備注：

網絡上很多其它文章還說明，需要刪除topic在zk上面的消費節點記錄、配置節點記錄，比如：

rmr /consumers/【consumer-group】

rmr /config/topics/【topic name】

其實正常情況是不需要進行這兩個操作的，如果需要，那都是由于操作不當導致的。比如step1停止生產和消費程序沒有做，step2沒有正確配置。也就是說，正常情況下嚴格按照step1 -- step5 的步驟，是一定能夠正常刪除topic的。

step6：

完成之后，調用命令：

./bin/kafka-topics.sh --list --zookeeper 【zookeeper server:port】

查看現在kafka的topic信息。正常情況下刪除的topic就不會再顯示。

但是，如果還能夠查詢到刪除的topic，則重啟zk和kafka即可。

總結

以上是生活随笔為你收集整理的kafka如何彻底删除topic及数据的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。