是什么导致我的 kafka 日志段被删除?
What is causing my kafka log segments to be deleted?
这些是我的设置
log.retention.check.interval.ms=300000
检查何时可以删除日志
log.retention.hours=168
非活动段在被删除之前必须存在多长时间
log.retention.ms=null
非活动段在被删除之前必须存在多长时间
log.retention.bytes=-1
非活动段必须有多大才能被删除
segment.ms=30000
在日志轮换之前必须有多少段。
据我所知,如果可能(这种情况正在发生),应该每 30 秒创建一个新的日志段。但是为什么删除旧的段呢?它不应该等待 168 小时吗(因为 log.retention.ms 为空)?
有一个 属性 我没有调查 "min.cleanable.dirty.ratio"。考虑到这一点后,我能够非常定期地触发压缩。
这些是我的设置
log.retention.check.interval.ms=300000
检查何时可以删除日志
log.retention.hours=168
非活动段在被删除之前必须存在多长时间
log.retention.ms=null
非活动段在被删除之前必须存在多长时间
log.retention.bytes=-1
非活动段必须有多大才能被删除
segment.ms=30000
在日志轮换之前必须有多少段。
据我所知,如果可能(这种情况正在发生),应该每 30 秒创建一个新的日志段。但是为什么删除旧的段呢?它不应该等待 168 小时吗(因为 log.retention.ms 为空)?
有一个 属性 我没有调查 "min.cleanable.dirty.ratio"。考虑到这一点后,我能够非常定期地触发压缩。