Kafka分区没有领导者

new9mtju  于 2023-04-05  发布在  Apache
关注(0)|答案(1)|浏览(228)

指定的主题正在应用程序中使用。

  • 这个主题实际上只有3个分区吗?那么向这个主题生成数据的应用程序在这3个分区中生成数据?
  • 主题是否有18个分区,但发送到15个无领导者分区的消息是否处于某种不确定状态或丢失?
  • 最后,如何解决这个问题。

我试着环顾四周,但我不确定这么多分区(18个中的15个)没有领导者的原因和影响是什么。

4nkexdtk

4nkexdtk1#

1.你的镜像显示了18个分区,而不是3个。集群只会 * 接受 * 对这3个有leader的工作主题的请求,所以“有效地”,是的。但是,Kafka生产者默认将数据散列到任何分区,而不是只选择那些有leader的。
1.该主题的复制因子为1。每个Leader: None输出都意味着不能向其写入数据,而不仅仅是分区15。实际上,分区15应该工作,因为它确实有一个leader。
1.您可以通过恢复这些分区所在的代理来修复它(也许Kafka进程在这些机器上崩溃了?)。看起来您至少有9个代理的集群。然后,您可以使用kafka-reassign-partitions.sh将该主题的复制因子增加到至少3个代理。

相关问题