即使经纪人都已满员，Kafka Preferred 领导者是否会更新？

偷偷努力，悄无声息地变强，然后惊艳所有人！哈哈，小伙伴们又来学习啦~今天我将给大家介绍《即使经纪人都已满员，Kafka Preferred 领导者是否会更新？》，这篇文章主要会讲到等等知识点，不知道大家对其都有多少了解，下面我们就一起来看一吧！当然，非常希望大家能多多评论，给出合理的建议，我们一起学习，一起进步！

我正在尝试制作一项kafka监控服务，该服务需要在集群中的每个代理上至少有一个主题分区。我最初分配了分区。我已将复制因子设置为 1，min.insync.replicas 也为 1，并且我使用 acks = all 的同步生产者进行生产。

分区代理分配最初看起来像这样

partition 0 : broker 0 (leader) , broker 0 (preferred leader) 
partition 1 : broker 1 (leader) , broker 1 (preferred leader) 
partition 2 : broker 2 (leader) , broker 2 (preferred leader)

当我尝试终止代理（例如代理 2）时，其领导者是该代理的分区应该并且正在报告“无领导者”错误。现在，由于我有 1 个复制，并且只有领导者是同步副本，kafka 不会重新选举任何其他代理作为领导者，这是预期的，直到这里一切都很好。

此时分区代理分配看起来像，

partition 0 : broker 0 (leader) , broker 0 (preferred leader)  
partition 1 : broker 1 (leader) , broker 1 (preferred leader)  
partition 2 : -1                , broker 2 (preferred leader)

问题：但是当该代理恢复时，分区的领导者和首选领导者都会更新为其他代理。我不明白这一点，也不期望如此。那么，我是否缺少任何配置，或者有人遇到过这个问题吗？

分区代理分配是这样的。为什么？？

Partition 0 : Broker 0 (Leader) , Broker 0 (Preferred Leader) 
Partition 1 : Broker 0 (Leader) , Broker 0 (Preferred Leader) 
Partition 2 : Broker 0 (Leader) , Broker 0 (Preferred Leader)

解决方案

kafka没有任何问题。我发现这是巡航控制自我修复，它没有按预期工作（不排除主题）。

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。