我想要经营多种卡夫卡经纪人。有一个名为server.properties的文件,在我的server.properties文件中有一个字段"log.retention.hours“设置为168。现在,如果我更改kafka代理属性文件,并在每个属性文件中设置不同的"log.retention.hours“值,那么它将如何在分布式环境中工作。我的意思是说,一个集群中的kafka代理复制了所有的分区,如果broker-1中的log.retention.hours与broker-2中的log.retention.hours不同会发生什么。分区的复制将如何进行。是否服务器-1中删除的数据将再次从其他代理复制(假设(server-1 log.retention.period) < (server-2 log.retention.period))。
发布于 2015-06-04 19:11:24
Kafka设计中的基本假设之一是集群中的代理将具有与描述的在这个卡夫卡的改进建议中相同的配置,只有极少数例外(例如端口)。因此,应该避免您在问题中描述的配置不一致的情况。
https://stackoverflow.com/questions/30644060
复制相似问题