1.案例
当kafka集群的broker节点宕机重启后,此broker节点的partition分区的leader节点会被选举为其它broker节点,此broker节点恢复后就会导致配分不均衡
可以看到所有partition的leader节点都在broker id为1的节点上,原来是平均分配到3个broker节点上,replicas项的首位就是表示原来的leader节点在哪个broker节点上
2.解决方法
观察isr列表是否三个broker节点都在,以保证三个broker节点数据一致性
bin/kafka-topics.sh --describe --bootstrap-server 10.1.60.114:9092 --topic apex
在任意kafka集群的broker节点执行以下命令,若有多个分区要重新选举则更改--partition项执行
/etc/kafka/kafka/bin/kafka-leader-election.sh --bootstrap-server 10.1.60.114:9092 --topic test --partition 1 --election-t