日志分段(Segment)策略
log.roll.hours/ms:日志滚动的周期时间,到达指定周期时间时,强制生成一个新的 Segment,默认值 168h(7day)。log.Segment.bytes:每个 Segment 的最大容量。到达指定容量时,将强制生成一个新的 Segment。默认值 1GB(-1 代表不限制)。log.retention.check.interval.ms:日志片段文件检查的周期时间。默认值 60000ms。
日志刷新策略
Kafka 的日志实际上是开始是在缓存中的,然后根据实际参数配置的策略定期一批一批写入到日志文件中,以提高吞吐量。
log.flush.interval.Messages:消息达到多少条时将数据写入到日志文件。默认值为 10000。log.flush.interval.ms:当达到该时间时,强制执行一次 flush。默认值为 null。log.flush.scheduler.interval.ms:周期性检查,是否需要将信息 flush。默认为很大的值。