kafka启动报错:The broker is trying to join the wrong cluster. Configured zookeeper.connect may be wrong.
前言今天启动了下kafka服务 发现报错了没办法只能找到问题点并解决下面是详细的排除步骤,亲测有效打开server.log 文件能看到这么一串报错信息kafka.common.InconsistentClusterIdException: The Cluster ID ueEeO4FGThWtPG0c7UzT2w doesn't match stored clusterId Some(ZRsnTy
·
前言
今天启动了下kafka服务 发现报错了
没办法只能找到问题点并解决
下面是详细的排除步骤,亲测有效
- 打开server.log 文件能看到这么一串报错信息
kafka.common.InconsistentClusterIdException: The Cluster ID ueEeO4FGThWtPG0c7UzT2w doesn't match stored clusterId Some(ZRsnTy4cSISZpsyDnVO4_g) in meta.properties. **The broker is trying to join the wrong cluster. Configured zookeeper.connect may be wrong.**
at kafka.server.KafkaServer.startup(KafkaServer.scala:218)
at kafka.Kafka$.main(Kafka.scala:109)
at kafka.Kafka.main(Kafka.scala)
- 首先翻译一下这段报错信息的意思
代理正在尝试加入错误的群集。配置的zookeeper.connect可能错误
所以我们先查看下kafka的配置
3. 打开配置文件 找到对应配置的日志目录下
- 打开meta.properties
-
找到此节点的日志并删除
更新cluster.id =【此值填写server.log的error报错的Cluster ID】从日志路径目录中删除此文件。
更多推荐
已为社区贡献2条内容
所有评论(0)