Deprecated: Optional parameter $keys declared before required parameter $cms_id is implicitly treated as a required parameter in /home/www/dev/work/class/blog/CmsKey.php on line 75

Deprecated: Creation of dynamic property lvesu\lvesu\controller\blog\main::$outlink is deprecated in /home/www/dev/work/website/lvesu/template/blog/cms/cms.tpl on line 2

Deprecated: Creation of dynamic property lvesu\lvesu\controller\blog\main::$status is deprecated in /home/www/dev/work/website/lvesu/template/blog/index.head.php on line 2
kafka:The broker is trying to join the wrong cluster. Configured zookeeper.connect may be wrong. - 互联网笔记

略微加速

略速 - 互联网笔记

kafka:The broker is trying to join the wrong cluster. Configured zookeeper.connect may be wrong.

2022-10-19 leiting (2414阅读)

标签 软件

kafka报错:

kafka.common.InconsistentClusterIdException: The Cluster ID maJBPe3TQKaMkjbR2HZzKw doesn't match stored clusterId Some(wtu_13-6Qna6GAmqpVSi1w) 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:223)

        at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44)

        at kafka.Kafka$.main(Kafka.scala:82)

        at kafka.Kafka.main(Kafka.scala)


解决:

在Kafka的config目录中,打开kafka config属性文件,让server.properties查找具有参数log.dirs=的日志路径目录(log文件),然后转到日志路径目录并在其中找到文件meta.properties。打开文件meta.properties并更新cluster.id=【这个值是error里面有写的】或从日志路径目录中删除此文件或所有日志文件(本人使用),然后重新启动kafka。


北京半月雨文化科技有限公司.版权所有 京ICP备12026184号-3