【背景】 kafka版本:0.9版本 2个kafka,2个副本 【问题描述】zookeeper网络问题,导致kafka重新注册到zookeeper中,出现下面问题: 生产者找不到某个broker中topic下的分区的leader(出问题的是broker的分区leader不可用) kafka重新注册后的broker路径没有读取配置的路径,问题路径是:/brokers/ids/1 配置的路径是:/kafka/brokers/ids/1
重新注册的时候,是否修改了zookeeper的地址。
重新注册后,kafka恢复了
日志上显示的是不是kafka注册到zk的真实地址?如果不是,那这个问题就是网络导致的了
没明白你的意思。
解决了,是kafka的问题,在1.1.0版本修复
ok
你的答案