当领导人选举发生错误时,Kafka经纪人从zookeeper中删除

m1m5dgzv  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(239)

今天我遇到一个问题,经纪人2是不存在的Zookeeper,我认为博克2是下降,但它仍然运行良好。我查了Zookeeper的日志,
它只提到“为客户机代理2建立了会话0x153514345be0321,协商超时6000”,
从移除的代理服务器和状态更改日志中,
[2016-03-08 06:00:00257]错误控制器2 epoch 19启动了分区[robotevents,186]的状态更改,从offlinepartition到onlinepartition失败(state.change.logger)kafka.common.statechangefailedexception:在为分区[***,186]选择领导人时遇到错误,原因是:分区[***,186]的领导人选举中止,186]因为leaderandisr路径已经由另一个控制器写入。这可能意味着当前控制器2经历了软故障,而另一个控制器在epoch 20中被选中。。
很多这样的错误都会发生,从源代码来看,这个错误在领导人选举过程中似乎是正常的,但是它不能解释为什么broker2被从zk中删除。你知道吗?
提前谢谢

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题