我正在执行Kafka代理从2.2.1到3.2.0（从cp 5.2.2到7.2.1）的滚动升级。这是在kafka集群上进行的滚动升级。有三个pod，即kafka-0、kafka-1和kafka-2。本主题的复制因子为2。在此滚动升级过程中，我面临停机，因为没有为“测试”分区分配leader。
无法获取主题测试分区4的领导者：Kafka服务器：在领导者选举过程中，此分区当前没有领导者，因此无法写入
当我添加日志时，我可以看到Partition leader=-1
我尝试增加其中一个主题的复制因子，它起作用了，但没有具体的原因为什么会发生这种情况
1条答案
按热度按时间c2e8gylq1#
您可能有
min.in.sync.replicas=2和unclean.leader.election=false，因此，当前的领导者关闭时，它没有完全复制，因此没有其他副本将取代它。您有3个代理，因此除了保存成本之外，没有理由不将复制因子设为3，同时在丢失任何一个副本时会以不可用为代价。