程序员经验分享-hwhale

ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) kafka.c

2023-10-31

kafka启动时报错如下：

[2021-12-28 23:35:02,165] ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
kafka.common.InconsistentClusterIdException: The Cluster ID eq9F2UfWTVqmKCEial0hrw doesn't match stored clusterId Some(43bjl8_0Qoe6Pw3psZjroA) 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:218)
	at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44)
	at kafka.Kafka$.main(Kafka.scala:84)
	at kafka.Kafka.main(Kafka.scala)

报错截图如下：
请添加图片描述
大概意思如下：

集群 ID eq9F2UfWTVqmKCEial0hrw 与 meta.properties 中存储的 clusterId 
Some(43bjl8_0Qoe6Pw3psZjroA) 不匹配。
 代理正在尝试加入错误的集群。 配置的zookeeper.connect 可能是错误的。

更正一下，这里这个错误和Zookeeper是没有关系的，这个报错的意思集群id不匹配，即当前启动的id和 meta.properties里面的id不匹配，造成这样的原因通常是你为正确关闭kafka或者是关闭时出现异常导致的。

[lqs@bdc112 datas]$ pwd
/home/lqs/module/kafka_2.11-2.4.1/datas

在这里插入图片描述
在这里插入图片描述
就是这个文件里面的cluster.id不一样导致的，您只需要改成和您报错的那个id一样就可以了（不是报错括号里面的那个id哈，是第一个id号哈）
在这里插入图片描述
像我这样改好并保存就可以。

注意：如果您的集群都出现了这样的错误，记得每一个都去改，或群发一下也可以；

如果担心数据的丢失，有一种最简单的办法，即把kafka相关的datas目录和logs目录删除，再来重启kafka即可。

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

大数据开发平台搭建踩坑记录

kafka

scala

Zookeeper

分布式

ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) kafka.c 的相关文章

  • 如何初始化子类型中特征的值？

    如果我写 trait T val t 3 val u 1 t Nil class U extends T override val t 2 new U u 它表明了这一点 List 1 0 我应该如何更改上面的代码以使其显示以下内容 Lis

  • Scala 中的行聚合

    我正在寻找一种方法在 Scala 的数据框中获取一个新列来计算min max中的值col1 col2 col10对于每一行 我知道我可以使用 UDF 来做到这一点 但也许有一种更简单的方法 Thanks Porting 这个Python答案

  • Scala 功能设计模式目录

    一周以来我一直在阅读 Scala 编程 作者一步一步地介绍了该语言的元素 但我仍然很困惑何时使用演员 闭包 柯里化等功能性的东西 我正在寻找功能结构的典型用例或最佳实践的目录 我并不是说在 Scala 中重新实现像 GoF 这样的众所周知的

  • 如何从java程序的main方法调用Scala程序的main方法？

    假设我在 Java 项目中有一个 Scala 类和一个 Java 类 scala 类如下所示 class Sam def main args Array String Unit println Hello 如何从同一项目中存在的 java

  • 按元素聚合数组

    Spark scala 相当新 我想知道是否有一种简单的方法以按列方式聚合 Array Double 这是一个例子 c1 c2 c3 1 1 1 0 1 0 3 4 1 2 1 0 0 0 4 3 2 1 0 0 0 0 0 0 2 3 1

  • Scala：“递归值...需要类型”，但我只使用 Java 类型

    object Rec extends App val outStream new java io ByteArrayOutputStream val out new java io PrintStream new java io Buffe

  • 将 DOCTYPE 添加到 Scala XML 的最简单方法？

    我怎样才能在 Scala XML 中制作这个最小的 HTML5 p p 当然 在 Scala 中制作类似 HTML 的 XML 很简单 gt val html p p html scala xml Elem p p 但是 我怎样才能注入DO

  • Jack（Java Android 编译器套件）将如何影响 Scala 开发人员

    现在随着公告Jack https source android com source jack html谷歌阐明了 Java 与 Android 相关的可预见的未来 但这对 Scala 和其他基于 JVM 的语言开发人员有何影响 尤其 Sc

  • Scala 2.8 中 <:<、<%< 和 =:= 的含义是什么？它们的文档在哪里？

    我可以在 API 文档中看到Predef https scala lang org files archive api 2 8 2 scala Predef 24 html它们是通用函数类型 From gt To 的子类 但仅此而已 嗯什么

  • 导入 sbt 项目时出错，服务器访问错误，未解决的依赖项

    我正在尝试从 IntelliJ IDE 15 0 2 的 build sbt 中导入我的项目中的库 我不断收到未解决的依赖项错误 我尝试更新不同论坛的设置来解决该问题 但没有任何效果 我尝试过的几件事 使用代理设置更新 sbtconfig

  • 如何将 JVM 选项传递给 SBT 以在运行应用程序或测试用例时使用？

    我想在运行我的应用程序或通过 SBT 对应用程序进行测试时指定 JVM 选项 具体来说 我需要能够为 JVM 提供 Djava security policy 参数 以便加载我的策略并用于测试 我怎样才能用 SBT 做到这一点 With x

  • 一般处理枚举的 Scala 类

    我想创建一个通用类来保存枚举的值 并且还允许访问枚举的可能值 以属性编辑器为例 您需要知道属性的当前值 并且还需要能够知道该属性的其他合法值 并且枚举的类型不应该提前知道 您应该能够使用任何类型的枚举 我的第一个想法是这样的 class E

  • 如何最好地处理 Future.filter 谓词不满足类型错误

    我喜欢 scala 的类型安全性 但我不断遇到的一个运行时错误是 Future filter predicate is not satisfied 我知道为什么会出现此错误 只是寻求有关如何最好地解决此错误并优雅地处理它的建议 或者也许我做

  • 标识符中下划线的 Scala 风格指南

    我已经接受了许多其他语言的观点 即下划线在标识符中具有与字母表一样多的自由度 因此 v and v 另外 尾随下划线是受到推崇的避免与保留关键字产生歧义 class case val abc 0

  • 为 Apache Spark 示例运行 Cypher (CAPS)

    我知道这是一个广泛的问题 但这会对neo4j不属于某个领域的用户scala编程 我需要使用Apache Spark 项目的 Cypher https github com opencypher cypher for apache spark

  • 使一个 sbt 配置依赖于另一个配置

    sbt 文档显示了如何仅在项目之间声明依赖关系的示例 但我确信有方法可以声明一个配置依赖于另一个配置 就像测试配置使用编译配置中的类路径一样 如何声明我自己的配置 以便它依赖于编译配置生成的类路径 我更仔细地研究了建议的解决方案 然后又出现

  • Scala 中的模式匹配是如何在字节码级别实现的？

    Scala 中的模式匹配是如何在字节码级别实现的 是不是像一系列if x instanceof Foo 构造 还是其他什么 它对性能有何影响 例如 给出以下代码 来自Scala 示例 http www scala lang org docu

  • 如何强制 Spark 执行代码？

    我如何强制 Spark 执行对 map 的调用 即使它认为由于其惰性求值而不需要执行它 我试过把cache 与地图调用 但这仍然没有解决问题 我的地图方法实际上将结果上传到 HDFS 所以 它并非无用 但 Spark 认为它是无用的 简短回

  • 一起调用distinct和map会在spark库中抛出NPE

    我不确定这是否是一个错误 所以如果你这样做 d spark RDD String d distinct map x gt d filter equals x 您将获得 Java NPE 但是如果你做了一个collect之后立马distinc

  • 如何在“THEN”中打印“IF”条件的源代码

    我想在 THEN 部分打印 IF 条件的 Scala 源代码 例子 IF 2 2 lt 5 THEN println I am in THEN because sourceCodeOfCondition 现在我们跳过THEN部分 问题是 如

随机推荐

  • 【计算机毕业设计】深度学习的驾驶行为检测

    前言 大四是整个大学期间最忙碌的时光 一边要忙着准备考研 考公 考教资或者实习为毕业后面临的就业升学做准备 一边要为毕业设计耗费大量精力 近几年各个学校要求的毕设项目越来越难 有不少课题是研究生级别难度的 对本科同学来说是充满挑战 为帮助大

  • 某行业CTF一道流量分析题

    今晚看了一道题 记录学习下 给了一个hacktrace pcapng 分析主要内容如下 上传两个文件 一个mouse m2s 一个mimi zip 将其导出 mimi zip中存放着secret zip和key pcapng 不过解压需要密

  • EFilm 3.1 安装文件

    国外网站上找到的 拿出来分享下 第一部分 http download csdn net detail crazpro 9696368 第二部分 http download csdn net detail crazpro 9696402 第三

  • Java：Scanner中的nextInt()方法

    文章目录 方法 验证 方法 Scanner中的nextInt 只会读取数值 剩下 n 还没有读取 并将cursor放在本行中 相当于C语言里面的scanf d i 验证 为方便描述 创建一个Scanner 对象in 注 标准输入System

  • axios的三次封装

    1 第一次封装 把项目中所有请求做的相同的事情 baseURL timeout 请求 响应式 成功或失败的提示 封装到一个文件夹里 这个文件夹通常叫做utils axios封装 通用工具函数 引入axios import axios fro

  • jdk1.8的安装和环境变量的配置最新版（超详细，保姆级教程）

    目录 一 JDK的下载和安装 1 JDK的下载 1 方式一 通过下面的链接地址直接下载jdk1 8版本 2 方式二 通过Oracle官网进行下载 2 jdk的安装 二 环境变量的配置 1 通过jdk路径配置环境变量 2 通过JAVA HOM

  • 剑指Offer53Java代码

    public class T53 public static boolean match String str String pattern if str null pattern null return false return matc

  • leetcode85 合并两个有序数组

    题目 给你两个按 非递减顺序 排列的整数数组 nums1 和 nums2 另有两个整数 m 和 n 分别表示 nums1 和 nums2 中的元素数目 请你 合并 nums2 到 nums1 中 使合并后的数组同样按 非递减顺序 排列 注意

  • static在c语言中是什么意思,在C语言中static有什么含义

    2019 10 10阅读 64 最主要有两点用途 让一个变量长期有效 而不管其是在什么地方被申明 比如 intfun1 staticints value 0 那么fun1不管在什么地方被调用 当函数退出后 s value最后的值将一直会被系

  • MR（MapReduce）架构

    一 什么是MR MapReduce将复杂的 运行于大规模集群上的并行计算过程高度地抽了两个函数 Map和Reduce 二 为什么使用MR 特点 1 易于编程 只关心业务逻辑 它简单的实现一些接口 就可以完成一个分布式程序 2 良好的扩展性

  • 算法面试-深度学习基础面试题整理（2023.8.29开始）

    一 无监督相关 聚类 异常检测 1 常见的距离度量方法有哪些 写一下距离计算公式 1 连续数据的距离计算 闵可夫斯基距离家族 当p 1时 为曼哈顿距离 p 2时 为欧式距离 p gt 时 就是切比雪夫距离 余弦距离 其中 A 和B是要比较的

  • Java8 consumer接口

    Java8 consumer接口 1 由来 Consumer是Java 8中的一个函数式接口 它属于java util function包 该接口定义了一个具有单个输入参数并且没有返回值的操作方法accept 2 官方常见五种示例命令和说明

  • 大数据技术与原理 概述

    大数据概述 大数据的发展历程 第一阶段 萌芽期 20世纪90年代至21世纪初 第二阶段 成熟期 21世纪前十年 第三阶段 大规模应用期 2010年以后 大数据的特点 简称4V 数据量大 数据类型多 处理速度快 价值密度低 大数据的特征 全面

  • Makefile 中gcc -lm -ldl是什么意思？

    gcc lm ldl是什么意思 包含动态链接库 到书上出现gcc lm 的选项 甚是不解 在网上查阅了一些资料 访问了一些论坛整理下 初学linux和gcc C代码调用math h中的函数有问题 如sqrt函数 若如sqrt 3 0 则可以

  • ros-sensor_msgs::PointCloud2类型消息解读

    ROS中sensor msgs PointCloud2类型消息解读 实例 header seq 2116 stamp secs 1586919439 nsecs 448866652 frame id LidarSensor1 height

  • Kubernetes系列（二）架构及特性

    在了解了k8s的发展历程之后 正式进入到学习k8s的阶段 本文主要内容是K8S的整体架构的说明和K8S一些特性的概括 架构 如下图是K8S的整体架构图 Kubernetes属于主从分布式架构 主要由Master Node和Worker No

  • 线程中捕获异常

    总结 正常线程抛出异常时 在外部是捕捉不到的 当此类异常跑抛出时 线程就会终结 而对于主线程和其他线程完全不受影响 且完全感知不到某个线程抛出的异常 也是说完全无法catch到这个异常 解决方案 为线程添加未捕获异常处理器 Uncaught

  • 关于错误 TypeError: ‘list‘ object is not callable 的解决办法

    在使用类型转换的过程中 运行以下代码产生了错误 1 tuple 将一个序列转换成元组 list 10 20 30 tuple tuple list print tuple print type tuple 2 list 将一个序列转换成列表

  • ip68能达到什么程度防水_IP68级防水能防多少米

    IPX8级防水8是厂商自定义的 具体防水深度由客户根据对自身产品的了解以及要求而定 IP68是连接器防水等级标准的最高级别 大家都知道 看防水连接器防水性能如何 主要看IPXX的后面两位数字XX 第一位X是从0到6 最高等级为6 第2位X是

  • ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) kafka.c

    kafka启动时报错如下 2021 12 28 23 35 02 165 ERROR Fatal error during KafkaServer startup Prepare to shutdown kafka server Kafka

热门标签