在测试 kafka 集群时,关闭 kafka 后,再次启动 kafka 集群时,遇到此问题,具体内容如下:

FATAL [KafkaServer id=0] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
java.lang.RuntimeException: A broker is already registered on the path /brokers/ids/0

关于这个异常,其实很简单,因为 broker id 为全局唯一的,异常信息很明显的告诉我们 id 为 0 的代理已经被注册了,可以到自己的 /brokers/ids/ 下去看看,全部的 broker id 都存储在这儿;

关于这个问题的解决办法,我摸索出了三种,如下:

第一种:server.properties 入手

修改系统配置文件的 broker.id ,如 1、2、3 已经注册过了,就修改为 4、5、6,如果你从头到尾都是按照我的教程来的,那么就请修改 server_001.properties ,输入命令“ vi server_001.properties ” 修改完成后,保存即可正常启动了;

第二种:meta.properties 入手

如果按照我的教程来的,请到 “  ” 中找到 meta.properties 配置文件,输入命令 “ vi meta.properties ” 修改 broker.id 为全局唯一,

注:如果不是这个路径,请到配置文件 log.dir 所对应的目录下,即可找到 meta.properties 配置文件。

第三种:直接删除已经注册的 broker id

当 broker 启动后,会在zk新建一个znode,访问 zk 很简单,如果按照我的教程步骤来的,

输入命令 “ bin/zkCli.sh -server 192.168.1.23:2181 ” 链接到 zk 集群, 并执行 ls /brokers/ids 就可以看到zk中存的所有的broker id 了,
删除broker id,在新版本中输入命令 “ deleteall /broker/ids ” 进行删除,在旧版本中输入命令 “ rmr /brokers/ids ” 进行删除。

kafka 集群启动失败:FATAL [KafkaServer id=0] Fatal error during KafkaServer startup.相关推荐

  1. kafka-manager监控kafka集群启动失败

    使用kafka-manager监控kafka出错: 启动hadoop集群,启动zookeeper集群,启动kafka集群后,在启动kafka-manager监控kafka集群时,发现kafka-man ...

  2. 部署ElasticSearch集群启动失败

    今天一直在尝试部署启动ElasticSearch集群,但是在启动的时候一直处于报错的状态信息.鉴于之前部署的单节点ElasticSearch能够启动成功,所以排除了安装包的问题. 如下所示的报错信息: ...

  3. es集群启动失败failed to join

    情况:window,jdk8,一个bin下启动3个实例(不是3个bin目录) 启动时报错,报类似的错 failed to join ... failure when sending a validat ...

  4. kafka集群下载、启动、部署、测试

    文章目录 一.kafka基础操作 1. kafka下载 2. 解压 3. 重命名 4. 在kafka目录下创建 data 数据文件夹 5. 修改配置文件 6. 配置kafka环境变量 7. 刷新环境变 ...

  5. 【Kafka】 kafka集群升级导致broker.id发生变动变动引起的问题

    文章目录 1.概述 2.详情 发现问题 解决问题 1.概述 转载:http://791202.com/2020/02/01/bigdata/362/ 2.详情 最近遇到一个问题,由于kafka集群升级 ...

  6. 融云发送自定义消息_数据源管理 | Kafka集群环境搭建,消息存储机制详解

    一.Kafka集群环境 1.环境版本 版本:kafka2.11,zookeeper3.4 注意:这里zookeeper3.4也是基于集群模式部署. 2.解压重命名 tar -zxvf kafka_2. ...

  7. 数据源管理 | Kafka集群环境搭建,消息存储机制详解

    本文源码:GitHub·点这里 || GitEE·点这里 一.Kafka集群环境 1.环境版本 版本:kafka2.11,zookeeper3.4 注意:这里zookeeper3.4也是基于集群模式部 ...

  8. Kafka集群安装Version1.0.1(自带Zookeeper)

    1.说明 Kafka集群安装,基于版本1.0.1, 使用kafka_2.12-1.0.1.tgz安装包, 其中2.12是编译工具Scala的版本. 而且不需要另外安装Zookeeper服务, 使用Ka ...

  9. ELK集群+Kafka集群+FileBeat——命运多舛的安装采坑之路

    欢迎大家关注我的公众号,添加我为好友! 开始的时候感觉日志监控是比较NB的技术,感觉很神奇,那么多日志,为什么一下子就能够找到自己想要的?后来初步了解到了ELK(ElasticSearch + Log ...

最新文章

  1. 介绍如何安装project 2016方法
  2. C语言的指针*和引用
  3. 用MATLAB模拟天线接收信号时,突然出现一个干扰信号,并且干扰信号从0°开始,绕90°,观察SINR的变化规律
  4. Hive几种数据导入方式
  5. MYSQL查询空值/NULL值
  6. [dp][前缀和] Jzoj P5907 轻功(qinggong)
  7. java学习(175):method类反射机制
  8. Java 反射 set get
  9. 你不知道的 Web 性能优化 | 原力计划
  10. 10种进阶方法让你快速测试端口连通性
  11. 05人月神话阅读笔记
  12. 决策树(五)--OpenCV决策树
  13. 启动Tomcat出现Using CATALINA_BASE
  14. python将元祖设为整形_相识python --------str字符串 int整形 bool布尔值 tu元祖 set()集合 dict 字典的数据补充...
  15. 【三维路径规划】基于matlab狼群算法无人机三维路径规划【含Matlab源码 167期】
  16. 488. 祖玛游戏【我亦无他唯手熟尔】
  17. 招商银行深圳分行二面(技术面试)
  18. 人家出轨你为什么那么嗨
  19. 超微服务器主板ipmi证书,超微主板的服务器使用IPMI远程安装操作系统教程
  20. mysql inet aton ipv6_在MySQL中存储IPv6地址

热门文章

  1. version robot
  2. 在Vista以上版本运行WTL程序,有时候会提示“这个程序可能安装补正确...”的错误...
  3. 【JavaScript】理解与使用Javascript中的回调函数
  4. Linux系统管理技术手册——第6章 添加新用户
  5. Myeclipse10下载,安装,破解,插件,优化介绍.
  6. asp.net出现:当前标识(NT AUTHORITY\NETWORK SERVICE)没有对' '的写访问权限。
  7. if 判断成绩 ,整百制
  8. RxSwift之UI控件UITextField与UITextView扩展的使用
  9. HarmonyOS之系统设置项的查询和使用
  10. Plugin [id: 'org.jetbrains.kotlin.jvm'] was not found in any of the following sources: