分布式系统- kafka log.retention.hours在多个代理中的不一致性



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

Kafka设计中的一个基本假设是集群中的代理将具有与本Kafka改进建议中描述的相同的配置,除了极少数例外(例如port)。因此,应该避免您在问题中描述的配置不一致的场景。

最新更新