kafka报错:kafka.errors.NoBrokers Available,Close of session 0x100457e83740000 java.io.IOException 和 The broker is trying to join the wrong cluster

kafa使用时报错:kafka.errors.NoBrokers Available 的主要可能原因是:

1. 没有依次启动 zookeeper 和 kafka;

2. kafka配置文件中 host没有写对:例如有些是 localhost:9092(local版)

此时马上检查这两部分即可。

打开zookeeper报错:WARN  [NIOWorkerThread-5:NIOServerCnxn@373] - Close of session 0x100457e83740000 java.io.IOException: 远程主机强迫关闭了一个现有的连接。

解决:

需要删除zookeeper的log文件:例如windows的C:UsersAdministratorzookeeper-x.x.xdataversion-2
删除:zookeeper-x.x.x/data/version-2/ 下面的数据(即conf/zoo.cfg配置文件定义的dataDir=/home/zookeeper-x.x.x/data和dataLogDir=/home/zookeeper-x.x.x/logs 下的数据)

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

解决:

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

【注意:删除log文件夹会直接删除topics】

#

参考:

https://blog.csdn.net/reblue520/article/details/80553506

https://www.manongdao.com/article-2281758.html

原文地址:https://www.cnblogs.com/qi-yuan-008/p/13912143.html