2019-11-06 kafka数据保存时间的设置

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
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容