1、
server.properties新增配置auto.create.topics.enable=false，預設true
server.properties新增配置delete.topic.enable=true，預設為true
確保topic的producer和consumer客戶端全部停掉
2、
刪除topic
kafka-topics --delete --zookeeper 127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183 --topic test-topic
3、
然後手動刪除log.disrs路徑下，對應的topic_name資料夾，如果是多個borker則每 個broker都需要手動刪除
4、
開啟zkcli.cmd，訪問zookeeper
刪除以下路徑的topic
ls /config/topics
rmr /config/topics/topic_name
ls /consumers
ls /brokers/topics
rmr /brokers/topics/topic_name
ls /admin/delete_topics
rmr /admin/delete_topics/topic_name
5、
重啟zookeeper和kafka，檢視topic是否已刪除
kafka-topics.bat --list --zookeeper 127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183
生產環境最好關閉刪除topic的功能，delete.topic.enable=false，刪除可能會出現好多問題，kafka有自動清理日誌功能，log.retention.hours=168日誌預設保留時間7天 (168個小時)，直接使用新建立的topic做業務
刪除所有topic
1、刪除kafka的log.disrs目錄下所有日誌檔案
2、刪除zookeeper的data和log下資料檔案(保留myid)
3、重啟zookeeper和kafka
kafka刪除新建topic
原理翻譯可參考 刪除kafka的topic，參照 1 刪除kafka儲存目錄 server.properties檔案log.dirs配置，預設為 tmp kafka logs 相關topic目錄 2 kafka 刪除topic的命令是 bin kafka topics delete zookeepe...
kafka刪除topic資料
生產環境中，有乙個topic的資料量非常大。這些資料不是非常重要，需要定期清理。要求 預設保持24小時，某些topic 需要保留2小時或者6小時 主要有3個 1.基於時間 2.基於日誌大小 3.基於日誌起始偏移量 接下來，主要介紹基於時間的清除！kafka版本為 2.11 1.1.0 zk版本為 3...
Kafka徹底刪除topic
kafka預設僅做刪除標記，並沒有真實刪除，若要真實刪除topic server.properties新增 delete.topic.enable true，然後重啟 刪除測試 建立topic bin kafka topics.sh create zookeeper 127.0.0.1 2180 r...