kafka設置某個topic的數據過期時間

kafka 單獨設置某個topic的數據過期時間

kafka 默認存放7天的臨時數據，如果遇到磁盤空間小，存放數據量大，可以設置縮短這個時間。

全局設置

修改 server.properties

log.retention.hours=72
log.cleanup.policy=delete

單獨對某一個topic設置過期時間

但如果只有某一個topic數據量過大。
想單獨對這個topic的過期時間設置短點：

./kafka-configs.sh --zookeeper localhost:2181 --alter --entity-name mytopic --entity-type topics --add-config retention.ms=86400000

retention.ms=86400000 為一天，單位是毫秒。

查看設置：

$ ./kafka-configs.sh --zookeeper localhost:2181 --describe --entity-name mytopic --entity-type topics
Configs for topics:wordcounttopic are retention.ms=86400000

立即刪除某個topic下的數據

./kafka-topics.sh --zookeeper localhost:2181 --alter --topic mytopic --config cleanup.policy=delete