apache-kafka - Kafka - 为什么没有选出新的主题分区领导者？

Question

我有一个由 3 个节点组成的 kafka 集群。当节点 #3 死亡时，我的 _schemas主题停止正常运行，我看到了这一点:

kafka-topics --zookeeper localhost:2181 --topic _schemas --describe
Topic:_schemas  PartitionCount:1        ReplicationFactor:2     Configs:cleanup.policy=compact
    Topic: _schemas Partition: 0    Leader: -1      Replicas: 3,2   Isr: 2

所以似乎节点 #3 已经死了，这就是 Leader: -1指。但是为什么 Kafka 不继续像往常一样工作，分配 Node #2作为新的领导者并将数据复制到 #1所以我们有 2 个同步副本？

我在 kafka 日志中看到的错误:

kafka.common.NotAssignedReplicaException:
Leader 3 failed to record follower 2's position -1 since the replica is not 
recognized to be one of the assigned replicas 3 for partition <loop over many partitions>

Answer 1

我通过重新启动 Controller 代理解决了这个问题。每个 kafka 集群都有一个代理被选为 Controller ，因此它将协调领导者的选举。我们的情况是 Controller 卡住了。为了找到哪个broker是 Controller ，你可以去你的zkCli.sh访问你的kafka集群使用的zookeeper，然后做get /controller ，您将在那里看到 brokerId。
我通过重新启动 Controller 代理轻松解决了这个问题，祝你好运。