是什么导致我的 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"。考虑到这一点后,我能够非常定期地触发压缩。