日志相关¶

分段策略属性(详见 Kafka存储机制):

log.roll.{hours,ms}:
   日志滚动的周期时间，到达指定周期时间时，强制生成一个新的segment
   默认值: 168（7day）
log.segment.bytes:
   每个segment的最大容量。到达指定容量时，将强制生成一个新的segment
   默认值: 1G(-1为不限制)
log.retention.check.interval.ms:
   日志片段文件检查的周期时间
   默认值: 60000

日志刷新策略:

Kafka的日志实际上是开始是在缓存中的，然后根据策略定期一批一批写入到日志文件中去，以提高吞吐率

log.flush.interval.messages
    消息达到多少条时将数据写入到日志文件
    默认值: 10000
log.flush.interval.ms
    当达到该时间时，强制执行一次flush
    默认值: null
log.flush.scheduler.interval.ms
    周期性检查，是否需要将信息flush
    默认值: 很大的值

日志保存清理策略:

log.cleaner.enable=true

log.cleanup.polict
    日志清理保存的策略只有delete和compact两种
    默认值: delete
log.retention.hours
    日志保存的时间，可以选择hours,minutes和ms
    # log.retention.{hours,minutes,ms} 超出保留时间的日志执行cleanup.policy定义的操作
    默认值: 168(7day)
log.retention.bytes
    删除前日志文件允许保存的最大值
    默认值: -1
log.segment.delete.delay.ms
    日志文件被真正删除前的保留时间
    默认值: 60000
log.cleanup.interval.mins
    每隔一段时间多久调用一次清理的步骤
    默认值: 10
log.retention.check.interval.ms
    周期性检查是否有日志符合删除的条件（新版本使用）
    默认值: 300000ms

备注

这里特别说明一下，日志的真正清楚时间。当删除的条件满足以后，日志将被“删除”，但是这里的删除其实只是将该日志进行了“delete”标注，文件只是无法被索引到了而已。但是文件本身，仍然是存在的，只有当过了log.segment.delete.delay.ms 这个时间以后，文件才会被真正的从文件系统中删除。

参考:

https://www.cnblogs.com/angellst/p/9368493.html