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:\Users\Administrator\zookeeper-x.x.x\data\version-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

相关文章:

  • 2021-07-08
  • 2021-10-26
  • 2021-08-23
  • 2021-11-03
  • 2022-01-14
  • 2022-01-07
  • 2022-12-23
猜你喜欢
  • 2022-12-23
  • 2021-05-19
  • 2021-05-20
  • 2022-12-23
  • 2022-01-13
  • 2021-12-07
  • 2022-12-23
相关资源
相似解决方案