连接kafka消息队列报org.apache.kafka.clients.NetworkClient异常
启动kafka后，连接kafka消息队列报org.apache.kafka.clients.NetworkClient异常
could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)检查kafka运行日志，报The broker is trying to join the wrong cluster异常
[2024-11-06 16:31:11,219] ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
kafka.common.InconsistentClusterIdException: The Cluster ID QAy4XKSVSYWyIWRKCl3BBQ doesn't match stored clusterId Some(AMdXxjsGTe-ebuBwX0E57g) 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:252)at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44)at kafka.Kafka$.main(Kafka.scala:82)at kafka.Kafka.main(Kafka.scala)
[2024-11-06 16:31:11,221] INFO shutting down (kafka.server.KafkaServer)
[2024-11-06 16:31:11,223] INFO [feature-zk-node-event-process-thread]: Shutting down (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread)
[2024-11-06 16:31:11,224] INFO [feature-zk-node-event-process-thread]: Shutdown completed (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread)
[2024-11-06 16:31:11,224] INFO [feature-zk-node-event-process-thread]: Stopped (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread)
[2024-11-06 16:31:11,225] INFO [ZooKeeperClient Kafka server] Closing. (kafka.zookeeper.ZooKeeperClient)
[2024-11-06 16:31:11,329] INFO Session: 0x110085d708f0001 closed (org.apache.zookeeper.ZooKeeper)
[2024-11-06 16:31:11,329] INFO EventThread shut down for session: 0x110085d708f0001 (org.apache.zookeeper.ClientCnxn)
[2024-11-06 16:31:11,331] INFO [ZooKeeperClient Kafka server] Closed. (kafka.zookeeper.ZooKeeperClient)
[2024-11-06 16:31:11,335] INFO App info kafka.server for 0 unregistered (org.apache.kafka.common.utils.AppInfoParser)
[2024-11-06 16:31:11,336] INFO shut down completed (kafka.server.KafkaServer)
[2024-11-06 16:31:11,337] ERROR Exiting Kafka. (kafka.server.KafkaServerStartable)
[2024-11-06 16:31:11,337] INFO shutting down (kafka.server.KafkaServer)修改kafka日志目录的meta.properties文件的cluster.id值
cluster.id=AMdXxjsGTe-ebuBwX0E57g
version=0
broker.id=0最后再重启kafka，连接恢复正常
相关文章：
连接kafka消息队列报org.apache.kafka.clients.NetworkClient异常
启动kafka后，连接kafka消息队列报org.apache.kafka.clients.NetworkClient异常 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) 检查kafka运行日志，报The broker is trying to join the wrong clu…...
淘宝商品评论API：代码界的“买家秀”大揭秘
在淘宝这个神奇的购物天堂里，商品评论就像是隐藏的宝藏，等待着我们去挖掘。想象一下，如果你的代码能够自动获取这些评论，那岂不是像拥有了一台时光机，可以穿梭在买家的购物体验之中？今天，我们就…...
RabbitMQ队列详细属性（重要）
RabbitMQ队列详细属性 1、队列的属性介绍1.1、Type：队列类型1.2、Name：队列名称1.3、Durability：声明队列是否持久化1.4、Auto delete： 是否自动删除1.5、Exclusive：1.6、Arguments：队列的其他属性…...
游戏服务器和普通服务器的区别
服务器，顾名思义，是提供服务的设备，在计算机领域，服务器是指具有网络功能的高性能计算机，用于存储、处理和传输数据，而游戏服务器则是专门为游戏提供服务的服务器，它需要具备更高的性能、更稳定…...
Java 中的 Supplier：让数据生成更灵活
文章目录 1. Supplier 基础：无参返回，懒加载的利器2. 与 Optional 配合，优雅地处理默认值3. 惰性初始化缓存：提升性能4. 用于随机数、时间戳等动态数据的生成5. 结合 Stream 实现动态数据流6. 与工厂模式结合，动态创建…...
轻松理解操作系统 - Linux的数据块是如何储存数据的？
python入门 C入门 Linux 由于其开源、比较稳定等特点统治了服务端领域。 也因此，学习Linux 系统相关知识在后端开发等岗位中变得越来越重要，甚至可以说是必不可少的。 因为它的广泛应用，所以在程序员的日常工作和面试中，它都是经…...
青藤深度参编的终端安全国家标准正式发布
近日，国家市场监督管理总局、国家标准化管理委员会发布中华人民共和国国家标准公告，由TC260（全国网络安全标准化技术委员会）归口，公安部第三研究所牵头的GB/T 29240-2024《网络安全技术 终端计算机通用安全技术规范》&…...
软考：去中心化的部署有什么特点
微服务架构被认为是去中心化的，因为它具有以下特点 模块化：微服务架构将应用程序拆分为一系列小型服务，每个服务都是独立的模块，易于维护和扩展 。这种模块化设计使得每个服务可以独立于其他服务运行，没有单一的控制中…...
L8.【LeetCode笔记】回文数
1.题目 https://leetcode.cn/problems/palindrome-number/description/ 给你一个整数 x ，如果 x 是一个回文整数，返回 true ；否则，返回 false 。 回文数 是指正序（从左向右）和倒序（从右向左&…...
双版本android studio安装
安装双版本原因：不同的AS存在不兼容的情况，导致旧版本的项目在新项目下要各种修改，很讨厌，使用双版本，各使用各的就没有这样的问题了。 建议：先安装低版本安装版，再安装高版本免安装版…...
npm镜像的常用操作
查看当前配置的 npm 镜像 npm config get registry切换官方镜像 npm config set registry https://registry.npmjs.org/切换淘宝镜像(推荐) npm config set registry https://registry.npmmirror.com/切换腾讯云镜像 npm config set registry http://mirrors.cloud.tencent…...
Unity插件NodeCanvas之行为树的详细教程
文章目录 前言叶节点 Leafs1、行为 Action2、判断 Condition控制组件 Composites1、顺序执行器 Sequencer2、选择执行器 Selector3、概率选择执行器 Probability Selector4、权重选择执行器 Priority Selector5、平行执行器 Parallel6、轮流选择器 Flip Selector7、完整执行器 …...
Vue全栈开发旅游网项目(9)-用户登录/注册及主页页面开发
1.用户登录页面开发 1.查询vant组件 2.实现组件模板部分 3.模型层准备 4.数据上传 1.1 创建版权声明组件Copyright 新建文件：src\components\common\Copyright.vue <template><!-- 版权声明 --><div class"copyright">copyright xx…...
Flutter 的 Widget 概述与常用 Widgets 与鸿蒙 Next 的对比
一、Flutter 的 Widget 概述 Flutter 是 Google 开发的一款开源 UI 框架，旨在帮助开发者快速构建高性能、高保真度的移动、Web 和桌面应用程序。在 Flutter 中，UI 的构建完全是通过 Widget 来实现的。Widget 是 Flutter 中所有用户界面元素的基础构建块…...
微服务day04
网关 网关路由 快速入门 创建新模块：hm-gateway继承hmall父项目。 引入依赖：引入网关依赖和nacos负载均衡的依赖 <?xml version"1.0" encoding"UTF-8"?> <project xmlns"http://maven.apache.org/POM/4.0.0"…...
Spring Boot 集成JWT实现Token验证详解
文章目录 Spring Boot 集成JWT实现Token验证详解一、引言二、JWT和Token基础1、什么是Token2、什么是JWT3、JWT的结构4、JWT的工作原理 三、集成JWT1、引入JWT依赖2、创建Token工具类3、创建拦截器4、注册拦截器 四、总结 Spring Boot 集成JWT实现Token验证详解 一、引言 在现…...
如何快速搭建一个spring boot项目
一、准备工作 1.1 安装JDK：确保计算机上已安装Java Development Kit (JDK) 8或更高版本、并配置了环境变量 1.2 安装Maven：下载并安装Maven构建工具，这是Spring Boot官方推荐的构建工具。 1.3 安装代码编辑器：这里推荐使用Inte…...
学习笔记：黑马程序员JavaWeb开发教程(2024.11.9)
9.1 Mybatis-基础操作-环境准备 这里也没做，到时候写案例，如果需要环境配置什么的，可以看看这个 9.2 Mybatis-基础操作-删除 删除需要动态获取需要删除的id，使用方法传参，#{}的方式实现 在编写的delete方法中&a…...
【软考】系统分析师第二版 新增章节 第20章微服务系统分析与设计
微服务系统是一类基于微服务架构风格的分布式系统，它将应用程序拆分成多个独立的小型服务，每个服务都运行在独立的进程中，并采用轻量级通信协议进行通信。这些服务可以由不同的团队开发、不同的编程语言编写，并且可以按需部署。微…...
抓包工具WireShark使用记录
目录 网卡选择： 抓包流程： 捕获过滤器 常用捕获过滤器： 抓包数据的显示 显示过滤器： 常用的显示过滤器： 实际工作中，在平台对接，设备对接等常常需要调试接口，PostMan虽然可以进…...
idea大量爆红问题解决
问题描述 在学习和工作中，idea是程序员不可缺少的一个工具，但是突然在有些时候就会出现大量爆红的问题，发现无法跳转，无论是关机重启或者是替换root都无法解决 就是如上所展示的问题，但是程序依然可以启动。 问题解决…...
QMC5883L的驱动
简介 本篇文章的代码已经上传到了github上面，开源代码 作为一个电子罗盘模块，我们可以通过I2C从中获取偏航角yaw，相对于六轴陀螺仪的yaw，qmc5883l几乎不会零飘并且成本较低。 参考资料 QMC5883L磁场传感器驱动 QMC5883L磁力计…...
对WWDC 2025 Keynote 内容的预测
借助我们以往对苹果公司发展路径的深入研究经验，以及大语言模型的分析能力，我们系统梳理了多年来苹果 WWDC 主题演讲的规律。在 WWDC 2025 即将揭幕之际，我们让 ChatGPT 对今年的 Keynote 内容进行了一个初步预测，聊作存档。等到明…...
vue3 定时器-定义全局方法 vue+ts
1.创建ts文件 路径：src/utils/timer.ts 完整代码： import { onUnmounted } from vuetype TimerCallback (...args: any[]) > voidexport function useGlobalTimer() {const timers: Map<number, NodeJS.Timeout> new Map()// 创建定时器con…...
在QWebEngineView上实现鼠标、触摸等事件捕获的解决方案
这个问题我看其他博主也写了，要么要会员、要么写的乱七八糟。这里我整理一下，把问题说清楚并且给出代码，拿去用就行，照着葫芦画瓢。 问题 在继承QWebEngineView后，重写mousePressEvent或event函数无法捕获鼠标按下事…...
return this；返回的是谁
一个审批系统的示例来演示责任链模式的实现。假设公司需要处理不同金额的采购申请，不同级别的经理有不同的审批权限： // 抽象处理者：审批者 abstract class Approver {protected Approver successor; // 下一个处理者// 设置下一个处理者pub…...
LLaMA-Factory 微调 Qwen2-VL 进行人脸情感识别（二）
在上一篇文章中，我们详细介绍了如何使用LLaMA-Factory框架对Qwen2-VL大模型进行微调，以实现人脸情感识别的功能。本篇文章将聚焦于微调完成后，如何调用这个模型进行人脸情感识别的具体代码实现，包括详细的步骤和注释。 模型调用步骤 环境准备：确保安装了必要的Python库。…...
【若依】框架项目部署笔记
参考【SpringBoot】【Vue】项目部署_no main manifest attribute, in springboot-0.0.1-sn-CSDN博客 多一个redis安装 准备工作： 压缩包下载：http://download.redis.io/releases 1. 上传压缩包，并进入压缩包所在目录，解压到目标…...
32位寻址与64位寻址
32位寻址与64位寻址 32位寻址是什么？ 32位寻址是指计算机的CPU、内存或总线系统使用32位二进制数来标识和访问内存中的存储单元（地址），其核心含义与能力如下： 1. 核心定义 地址位宽：CPU或内存控制器用32位…...
dvwa11——XSS(Reflected)
LOW 分析源码：无过滤 和上一关一样，这一关在输入框内输入，成功回显 <script>alert(relee);</script> MEDIUM 分析源码，是把<script>替换成了空格，但没有禁用大写 改大写即可，注意函数…...