是什么导致我的Kafka日志段被删除？

m2xkgtsf 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(257)

这些是我的设置 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为空）？

apache-kafka Logging segments

来源：https://stackoverflow.com/questions/43689111/what-is-causing-my-kafka-log-segments-to-be-deleted