kafka更换zk节点

问题

kafka无法连接,查看端口9092还在,进程也在,但是无法连接。

file

查看kafka日志报错zk无法连接

file

查看kafka配置文件,zookeeper.connect配置的zk节点所在的系统盘挂了,无法连接,需要更换zk节点。

解决

修改配置文件,将zk地址更换为新节点的zk,启动kafka报错:The Cluster ID _njFkju7RGaaBo6C8_um5A doesn't match stored clusterId Some(Z7gCHriVQfagZafx1r6XTg) in meta.properties

file

zk中存储的clusterID和kafka元数据meta.properties中的id不一致,导致连接zk失败。

有两种方法,

  • 删除meta.properties中的信息,备份并删除kafka数据目录,重新初始化。
  • 重新初始化zk

zk是新的zk,所以选择初始化zk,也就是修改zk中的id和kafka一致。

./zkCli.sh -server 1.2.3.4:2181

set /kafka_new/cluster/id {"version":"1","id":"Z7gCHriVQfagZafx1r6XTg"}

file

重新启动kafka,正常启动。

file

可以正常连接。

file

0 0 投票数
文章评分
订阅评论
提醒
guest

0 评论
最旧
最新 最多投票
内联反馈
查看所有评论

相关文章

开始在上面输入您的搜索词,然后按回车进行搜索。按ESC取消。

返回顶部
0
希望看到您的想法,请您发表评论x