kafka默认的只保存7天的数据,时间一到就删除数据,当遇到磁盘过小,,存放的数据量过大,可以设置缩短这个时间。
设置全局配置
log.retention.hours=72
log.cleanup.policy=delete
对单独的某一个topic设置过期的时间
./kafka-config.sh --zookeeper localhost:2181 --alter --entity-name mytopic --entity_type topics --add-config retention.ms=86400000
查看设置
./kafka-config --zookeeper localhsot:2181 --describle --entity-name mytopic --entity_type topics
立即删除某个topic下面的数据
./kafka-topic.sh --zookeeper localhost:2181 --alter --topic mytopic --config cleanup.policy=delete
网友评论