zoukankan      html  css  js  c++  java
  • 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

  • 相关阅读:
    DELPHI开发LINUX包
    DELPHI开发LINUX的动态库
    中间件测试工具
    CENTOS7安装OPENSSL
    咏南跨平台中间件简介
    IdHTTPServer开发https服务器
    ServiceStack.Redis常用操作
    ServiceStack.Redis 之 IRedisTypedClient<第四篇>
    Redis常用命令速查 <第二篇>
    ServiceStack.Redis之IRedisClient<第三篇>
  • 原文地址:https://www.cnblogs.com/qi-yuan-008/p/13912143.html
Copyright © 2011-2022 走看看