博主,你好:
目前遇到一个问题就是一台kafka节点重启的时候如下的异常:
这个异常是在controller日志里面显示的,表示是在更新broker节点元数据的时候,连接失败。
目前由于开启了auto.leader.rebalance.enable,所以在重启节点的时候,就会出现某些分区数据少,先同步完,然后进行leader的切换。切换完成以后客户端就会来连接当前的broker。但是由于controller在更新这台节点元数据的时候是没有更新成功的,就会导致元数据不一致,客户端读写数据失败问题。
同时在broker的日志里面可以看到如下异常:
目前尝试调整network,io,fetcher等线程数量,但是没有作用。
博主是否有遇到过这样的异常