kafka刪除主題資料和刪除主題
阿新 • • 發佈:2019-02-08
kafka使用confluent-3.1.2 刪除的主題名:test
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 //保留時間檢查間隔,單位毫秒