apache-kafka - Kafka 压缩主题,retention.ms 是否适用于它们?
问题描述
由于我们将 Kafka 从 2.0.0 升级到 2.3.0,对于压缩主题,我们在日志中看到以下消息:
INFO [Log partition=compactedTopic-40, dir=/data/kafka/kafka] Found deletable segments with base offsets [106539766] due to retention time 432000000ms breach
当主题的政策刚刚设置为时,这对我来说没有多大意义compact
。
那432000000ms
是代理值,log.retention.ms
我们没有retention.ms
在压缩主题配置中进行配置。
有什么方法可以影响压缩主题(策略设置为compact
,而不是compact,delete
)log.retention.ms
?
检查 Kafka 源代码告诉我,打印该消息的唯一方法是 config 上有delete
字符串:https ://github.com/apache/kafka/blob/2.3/core/src/main/scala/kafka/日志/Log.scala#L1576
无论如何,您是否可以想到为什么我们会在压缩主题的日志中看到此消息?
这可能是Kafka中的错误吗?
谢谢