kafka日志保留时间

相关参数

#设置日志只保留一个小时的
  "log.retention.hours": 1
#设置大于500M就自动删除(默认1G)
  "log.retention.bytes": "536870912"
#设置日志被标记删除后,保留多久彻底删除,1分钟
  "log.segment.delete.delay.ms": 60000
#设置多久扫描一次要清理的日志
  "log.cleanup.interval.mins": 3
#设置多久新建一个segment(默认值7天)
	log.roll.hours
#设置日志超过多大新建一个segment(默认1G)
	log.segment.bytes
#设置是否开启日志清理
  log.cleaner.enable

修改了kafka日志保留天数后没有立即生效的原因

  1. kafka只会回收上个segment数据,还没到log.roll.hours设置的时间或者log.segment.bytes设置的大小

  2. log.cleaner.enable需要设置为true

  3. log.segment.delete.delay.ms设置的时间之后才能被真正删除


kafka日志保留时间
https://www.hechunyu.com/archives/1698219472940
作者
chunyu
发布于
2022年07月25日
许可协议