【发布时间】:2021-03-10 11:05:48
【问题描述】:
在 kafka 中有一个 log.retention.ms 配置属性,可以在 Broker 级别设置,并且可以在主题级别被 retention.ms 覆盖。
想象一下,我的 Kafka 集群中有一个默认配置的主题 - 没有明确设置保留。当我创建主题时,Broker 级别 log.retention.ms 设置为 7 天。与此同时,我将此设置更改为 30 天。这是否意味着我现有的主题将使用创建主题时(7 天)时存在的配置,还是现在使用 30 天的新代理配置?
由于kafka-topics.sh --describe --topic foo 时未显示主题级别的未显式设置配置值,我发现很难验证。
【问题讨论】:
标签: apache-kafka retention kafka-topic