使用kafka-delete-records.sh或者kafka-delete-records.bat， 指定對應的**和刪除資訊的json檔案即可。
kafka-delete-record.bat的幫助資訊
建立的乙個topic, 有三個broker和 三個partition
這裡由於是建立了三個broker, 因此需要指定三個--bootstrap-server， json檔案如下：
把這個json檔案命名為delete_partitions.json， 放到 kafka 解壓後的目錄下， 與bin目錄同級。
windows 上，.\bin\windows\kafka-delete-records.bat --bootstrap-server 127.0.0.1:9092,127.0.0.1:9093,127.0.0.1:9094 --offset-json-file .\delete_partitions.json即可清除當前三個分割槽、三個broker的所有資訊記錄。
unix 下直接執行bin目錄下的kafka-delete-records.sh即可， 引數與上面一致。
Kafka主題 topic 的刪除
step1 如果需要被刪除topic 此時正在被程式 produce和consume，則這些生產和消費程式需要停止。因為如果有程式正在生產或者消費該topic，則該topic的offset資訊一致會在broker更新。呼叫kafka delete命令則無法刪除該topic。同時，需要設定 auto....
kafka刪除主題資料和刪除主題
1 刪除主題 在server.properties中增加設定，預設未開啟 delete.topic.enable true 刪除主題命令 bin kafka topics delete topic test zookeeper localhost 2181 2 刪除主題資料 如果想保留主題，只刪除主...
Kafka刪除主題詳解
在kafka的使用 測試過程中，可能老是會遇到想要刪除某個主題的需求，但是由於對其內部機制不夠了解，總是無法有效的刪除主題。今天這篇文章詳細討論如何徹底的刪除乙個主題。在kafka的broker端的配置引數中有這樣乙個引數 delete.topic.enable，必須將它設定為true才能夠刪除ka...