1、刪除主題
在server.properties中增加設定，預設未開啟
delete.topic.enable=true
刪除主題命令
/bin/kafka-topics --delete --topic test --zookeeper localhost:2181
2、刪除主題資料
如果想保留主題，只刪除主題現有資料（log）。可以通過修改資料保留時間實現
bin/kafka-configs --zookeeper localhost:2181 --entity-type topics --entity-name test --alter --add-config retention.ms=3000### 修改保留時間為三秒，但不是修改後三秒就馬上刪掉，kafka是採用輪訓的方式，輪訓到這個主題發現三秒前的資料都是刪掉。時間由自己在server.properties裡面設定，設定見下面。
資料刪除後，繼續使用主題，那主題資料的保留時間就不可能為三秒，所以把上面修改的配置刪掉，採用server.properties裡面統一的配置。
bin/kafka-configs --zookeeper localhost:2181 --entity-type topics --entity-name test --alter --delete-config retention.ms
server.properties裡面資料保留時間的配置
log.retention.hours=168//保留時間，單位小時
log.retention.check.interval.ms=300000
//保留時間檢查間隔，單位毫秒
ref:
Kafka刪除主題詳解
在kafka的使用 測試過程中，可能老是會遇到想要刪除某個主題的需求，但是由於對其內部機制不夠了解，總是無法有效的刪除主題。今天這篇文章詳細討論如何徹底的刪除乙個主題。在kafka的broker端的配置引數中有這樣乙個引數 delete.topic.enable，必須將它設定為true才能夠刪除ka...
Kafka主題 topic 的刪除
step1 如果需要被刪除topic 此時正在被程式 produce和consume，則這些生產和消費程式需要停止。因為如果有程式正在生產或者消費該topic，則該topic的offset資訊一致會在broker更新。呼叫kafka delete命令則無法刪除該topic。同時，需要設定 auto....
kafka刪除topic資料
生產環境中，有乙個topic的資料量非常大。這些資料不是非常重要，需要定期清理。要求 預設保持24小時，某些topic 需要保留2小時或者6小時 主要有3個 1.基於時間 2.基於日誌大小 3.基於日誌起始偏移量 接下來，主要介紹基於時間的清除！kafka版本為 2.11 1.1.0 zk版本為 3...