多个经纪人中的kafka log.retention.hours不一致

Question

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

Answer 1

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