log.retention.{ms,minutes,hours}:  Kafka segment log的保存周期, 默认保存7天

 

1. 把retention.ms 改小， 如1000ms, 即1分钟

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

查看设置是否成功：

./kafka-configs.sh –zookeeper localhost:2181 –entity-type topics –describe –entity-name MyTopic

 

2. 5分钟后，查看日志文件是否已经删除或者文件大小是否变小

ls -l /tmp/kafka-logs/MyTopic-0/

为什么是5分钟？ 跟这个配置有关， log.retention.check.interval.ms: 删除策略的检查周期

 

3. 把retention.ms 恢复原值

./kafka-configs.sh –zookeeper localhost:2181 –entity-type topics –alter –delete-config retention.ms –entity-name MyTopic

 

版权声明：本文为robynn原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：http://www.cnblogs.com/robynn/p/7883861.html