0.8的官方文件提供了乙個刪除topic的命令：
kafka-topics.sh --delete 但是在執行時會報錯找不到這個方法。
kafka-topics.sh最終是執行了kafka.admin.topiccommand這個類，在0.8的原始碼中這個類中沒有找到有delete topic相關的**。
在kafka的admin包下，提供了乙個deletetopiccommand的類，可以實現刪除topic的功能。
kafka.admin.deletetopiccommand
其中刪除topic的具體實現**如下：
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
importorg.i0itec.zkclient.zkclient
importkafka.utils.
.......
val topic = options.valueof(topicopt)
val zkconnect = options.valueof(zkconnectopt)
var zkclient: zkclient =null
try
catch
finally
因為這個命令只會刪除zk裡面的資訊，真實的資料還是沒有刪除，所以需要登入各個broker,把對應的topic的分割槽資料目錄刪除，也可能正因為這一點，delete命令才沒有整合到kafka.admin.topiccommand這個類。
徹底刪除kafka的topic方法
1 刪除kafka儲存目錄 server.properties檔案log.dirs配置，預設為 tmp kafka logs 相關topic目錄 2 kafka 刪除topic的命令是 kafka bin kafka topics.sh delete zookeeper zookeeper位址 to...
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...