我想缩短其中一个 Kafka 主题的保留期。我希望其余主题仍使用默认保留时间(7 天)。
我知道我们可以通过终端进行设置:bin/kafka-topics.sh --zookeeper XXX --alter --topic XXXX --config replacement.ms=86400000。
我想知道是否有办法做到这一点，以便将其设置在 server.properties 中并可以在将来使用。例如，对于默认保留时间，我们有 log.retention.months = XXX。
编辑:经过一些研究，我注意到每个主题的配置应该更好地在 ZK 中以这种方式完成( https://issues.apache.org/jira/browse/KAFKA-554 )。但我仍然想知道是否可以通过编程方式而不是使用 kafka-topics.sh 来完成此操作。
最佳答案
如果您只希望某些主题具有不同的保留时间，恐怕您必须在使用 kafka-topics.sh 创建它们时指定它。
在 server.properties 中，您只能指定适用于所有没有覆盖的主题的配置。
关于apache-kafka - server.properties 中每个主题的 Kafka 日志保留时间，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/47294794/