指定的主题正在应用程序中使用。
我试着环顾四周，但我不确定这么多分区（18个中的15个）没有领导者的原因和影响是什么。
4nkexdtk1#
1.你的镜像显示了18个分区，而不是3个。集群只会 * 接受 * 对这3个有leader的工作主题的请求，所以“有效地”，是的。但是，Kafka生产者默认将数据散列到任何分区，而不是只选择那些有leader的。1.该主题的复制因子为1。每个Leader: None输出都意味着不能向其写入数据，而不仅仅是分区15。实际上，分区15应该工作，因为它确实有一个leader。1.您可以通过恢复这些分区所在的代理来修复它（也许Kafka进程在这些机器上崩溃了？）。看起来您至少有9个代理的集群。然后，您可以使用kafka-reassign-partitions.sh将该主题的复制因子增加到至少3个代理。
Leader: None
kafka-reassign-partitions.sh
1条答案
按热度按时间4nkexdtk1#
1.你的镜像显示了18个分区，而不是3个。集群只会 * 接受 * 对这3个有leader的工作主题的请求，所以“有效地”，是的。但是，Kafka生产者默认将数据散列到任何分区，而不是只选择那些有leader的。
1.该主题的复制因子为1。每个
Leader: None输出都意味着不能向其写入数据，而不仅仅是分区15。实际上，分区15应该工作，因为它确实有一个leader。1.您可以通过恢复这些分区所在的代理来修复它（也许Kafka进程在这些机器上崩溃了？）。看起来您至少有9个代理的集群。然后，您可以使用
kafka-reassign-partitions.sh将该主题的复制因子增加到至少3个代理。