首页 > 解决方案 > 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,deletelog.retention.ms

检查 Kafka 源代码告诉我,打印该消息的唯一方法是 config 上有delete字符串:https ://github.com/apache/kafka/blob/2.3/core/src/main/scala/kafka/日志/Log.scala#L1576

无论如何,您是否可以想到为什么我们会在压缩主题的日志中看到此消息?

这可能是Kafka中的错误吗?

谢谢

标签: apache-kafka

解决方案


推荐阅读