我两套用的一个zk,配置不同的根目录
集群A的zk配置:
zookeeper.connect=1.zookeeper1001.bip.com.cn:2181,2.zookeeper1001.bip.com.cn:2181,3.zookeeper1001.bip.com.cn:2181/kafka/1004
集群B的zk配置:
zookeeper.connect=1.zookeeper1001.bip.com.cn:2181,2.zookeeper1001.bip.com.cn:2181,3.zookeeper1001.bip.com.cn:2181/kafka/2021
kafka是通过broker来确认身份的,通过zk来绑定集群的。
你起B,A会有反应,说明问题在zk。
你报错的信息就是API版本差异呀,说明集群版本成员版本不一致。
你zk的脏数据影响的,或者删,或者broker.id换成新的。
ps(你补充一下2个kafka连接zk的配置,内部ip的话,暴露外网也没关系,尽量真实,我要确认集群)