kafka log.retention.hours 多个代理中的不一致

kafka log.retention.hours inconsistency in multiple brokers

我正在尝试 运行 多个 kafka 代理。有一个名为 server.properties 的文件,并且有一个字段 "log.retention.hours" 在我的 server.properties 文件中设置为 168。现在,如果我更改 kafka 代理属性文件并在每个属性文件中设置不同的 "log.retention.hours" 值,那么它将如何在分布式环境中运行。我的意思是说,单个集群中的 kafka 代理会复制所有分区,如果 broker-1 中的 log.retention.hours 与 broker-2 中的 log.retention.hours 不同,将会发生什么情况。分区的复制将如何进行。 server-1 中已删除的数据是否会从其他代理再次复制(假设 (server-1 log.retention.period) < (server-2 log.retention.period))。

Kafka 设计中的一个基本假设是集群中的代理,除了极少数例外(例如端口),将具有与描述相同的配置 in this Kafka Improvement Proposal。因此,应避免您在问题中描述的配置不一致的情况。