首页 文章

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

提问于
浏览
1

我正在尝试运行多个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)) .

1 回答

  • 2

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

相关问题