1. 程式人生 > >kafka刪除主題資料和刪除主題

kafka刪除主題資料和刪除主題

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 //保留時間檢查間隔,單位毫秒