# 解压 tar -xzf kafka_2.13-3.2.3.tgz -C /opt/ # 创建数据目录 mkdir -p /data/kafka/kraft-metadata mkdir -p /data/kafka/kafka-logs /opt/kafka_2.13-3.2.3/bin/kafka-storage.sh random-uuid cd /opt mv kafka_2.13-3.2.3 kafkanode01 (192.168.47.149) 配置vim /opt/kafka/config/kraft/server.properties# 角色混合模式 process.rolesbroker,controller node.id1 # 控制器通信 controller.listener.namesCONTROLLER listenersPLAINTEXT://0.0.0.0:9092,CONTROLLER://0.0.0.0:9093 # 【重要】对外广播地址必须写本机IP advertised.listenersPLAINTEXT://192.168.47.149:9092 listener.security.protocol.mapCONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT # 仲裁组配置 (三个节点) controller.quorum.voters1192.168.47.149:9093,2192.168.47.150:9093,3192.168.47.151:9093 # 存储目录 log.dirs/data/kafka/kafka-logs metadata.log.dir/data/kafka/kraft-metadatanode02 (192.168.47.150) 配置process.rolesbroker,controller node.id2 controller.listener.namesCONTROLLER listenersPLAINTEXT://0.0.0.0:9092,CONTROLLER://0.0.0.0:9093 advertised.listenersPLAINTEXT://192.168.47.150:9092 listener.security.protocol.mapCONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT controller.quorum.voters1192.168.47.149:9093,2192.168.47.150:9093,3192.168.47.151:9093 log.dirs/data/kafka/kafka-logs metadata.log.dir/data/kafka/kraft-metadatanode03 (192.168.47.151) 配置process.rolesbroker,controller node.id3 controller.listener.namesCONTROLLER listenersPLAINTEXT://0.0.0.0:9092,CONTROLLER://0.0.0.0:9093 advertised.listenersPLAINTEXT://192.168.47.151:9092 listener.security.protocol.mapCONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT controller.quorum.voters1192.168.47.149:9093,2192.168.47.150:9093,3192.168.47.151:9093 log.dirs/data/kafka/kafka-logs metadata.log.dir/data/kafka/kraft-metadata格式化存储目录/opt/kafka/bin/kafka-storage.sh format \ -t 替换为步骤2生成的UUID \ -c /opt/kafka/config/kraft/server.properties启动验证集群/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/kraft/server.properties # 检查端口 (9093 是 Controller 通信端口) ss -tlnp | grep -E 9092|9093 # 查看启动日志确认无 Fatal 或 Error tail -f /opt/kafka/logs/server.log # 查看 Broker 列表 /opt/kafka_2.13-3.2.3/bin/kafka-broker-api-versions.sh --bootstrap-server 192.168.47.149:9092 /opt/kafka/bin/kafka-metadata-shell.sh --snapshot /data/kafka/kraft-metadata/__cluster_metadata-0/00000000000000000000.log ls brokers
Kafka-KRaft模式集群
发布时间：2026/5/23 15:02:00
# 解压 tar -xzf kafka_2.13-3.2.3.tgz -C /opt/ # 创建数据目录 mkdir -p /data/kafka/kraft-metadata mkdir -p /data/kafka/kafka-logs /opt/kafka_2.13-3.2.3/bin/kafka-storage.sh random-uuid cd /opt mv kafka_2.13-3.2.3 kafkanode01 (192.168.47.149) 配置vim /opt/kafka/config/kraft/server.properties# 角色混合模式 process.rolesbroker,controller node.id1 # 控制器通信 controller.listener.namesCONTROLLER listenersPLAINTEXT://0.0.0.0:9092,CONTROLLER://0.0.0.0:9093 # 【重要】对外广播地址必须写本机IP advertised.listenersPLAINTEXT://192.168.47.149:9092 listener.security.protocol.mapCONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT # 仲裁组配置 (三个节点) controller.quorum.voters1192.168.47.149:9093,2192.168.47.150:9093,3192.168.47.151:9093 # 存储目录 log.dirs/data/kafka/kafka-logs metadata.log.dir/data/kafka/kraft-metadatanode02 (192.168.47.150) 配置process.rolesbroker,controller node.id2 controller.listener.namesCONTROLLER listenersPLAINTEXT://0.0.0.0:9092,CONTROLLER://0.0.0.0:9093 advertised.listenersPLAINTEXT://192.168.47.150:9092 listener.security.protocol.mapCONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT controller.quorum.voters1192.168.47.149:9093,2192.168.47.150:9093,3192.168.47.151:9093 log.dirs/data/kafka/kafka-logs metadata.log.dir/data/kafka/kraft-metadatanode03 (192.168.47.151) 配置process.rolesbroker,controller node.id3 controller.listener.namesCONTROLLER listenersPLAINTEXT://0.0.0.0:9092,CONTROLLER://0.0.0.0:9093 advertised.listenersPLAINTEXT://192.168.47.151:9092 listener.security.protocol.mapCONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT controller.quorum.voters1192.168.47.149:9093,2192.168.47.150:9093,3192.168.47.151:9093 log.dirs/data/kafka/kafka-logs metadata.log.dir/data/kafka/kraft-metadata格式化存储目录/opt/kafka/bin/kafka-storage.sh format \ -t 替换为步骤2生成的UUID \ -c /opt/kafka/config/kraft/server.properties启动验证集群/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/kraft/server.properties # 检查端口 (9093 是 Controller 通信端口) ss -tlnp | grep -E 9092|9093 # 查看启动日志确认无 Fatal 或 Error tail -f /opt/kafka/logs/server.log # 查看 Broker 列表 /opt/kafka_2.13-3.2.3/bin/kafka-broker-api-versions.sh --bootstrap-server 192.168.47.149:9092 /opt/kafka/bin/kafka-metadata-shell.sh --snapshot /data/kafka/kraft-metadata/__cluster_metadata-0/00000000000000000000.log ls brokers
相关文章
你的EEPROM数据丢了吗？基于STM32和AT24CXX的I2C通信稳定性实战调优指南
EEPROM数据可靠性实战：STM32与AT24CXX的I2C通信深度优化 在工业控制、医疗设备和消费电子等领域，EEPROM作为非易失性存储器承担着关键参数存储的重任。但当系统突然断电或遭遇电磁干扰时，工程师们常会遇到数据丢失、校验失败等棘手问题。本文…
Linux的常用网络命令
计算机网络的主要优点是能够实现资源和信息的共享，并且用户可以远程访问信息。 Linux提供了一组强有力的网络命令来为用户服务，这些工具能够帮助用户登录到远程计算机上、传输文件和执行远程命令等。介绍下列几个常用的有关网络操作的命令：ft…
MPC5604B/C MC_CGM（时钟生成与MC_ME（模式控制）
一、前言 本文主要说明时钟从哪来、跑多快、内核跑不跑、哪些外设供电、哪些时钟打开、低功耗怎么进。 二、MC_CGM MC_CGM 就是时钟路由器 + 分频器：选择系统时钟源、分配时钟到内核 / 总线 / 外设。 2.1MC_CGM 核心功能 选择 SYSCLK 来源（FIRC / FXOSC / FMPLL） 3 路外设…
AssetRipper实战指南：Unity资源诊断与AB包健康度审计
1. 这不是“破解工具”，而是Unity开发者本该掌握的资源诊断能力 AssetRipper这个名字，第一次出现在我视野里，是在2022年一个Unity性能优化群里的深夜讨论。当时有位同事发来一张截图：某款上线半年的手游突然在iOS上出现纹理加载延…
统信UOS服务器版初体验：除了装软件，它的包管理、开发工具链和日常运维命令跟CentOS有啥不同？
统信UOS服务器版深度对比：从CentOS迁移必知的包管理、工具链与运维差异对于习惯了CentOS生态的运维工程师和开发者来说，首次接触统信UOS服务器版时，那种既熟悉又陌生的感觉尤为明显。命令行提示符依然闪烁，但yum变成了dnf…
ArcGIS Pro新手村：用DEM数据5分钟搞定坡度坡向分析（附等高线提取）
ArcGIS Pro新手村：用DEM数据5分钟搞定坡度坡向分析（附等高线提取）刚接触GIS的新手常被复杂的工具界面吓退，但地形分析其实可以像搭积木一样简单。想象你手头有一份数字高程模型（DEM）数据，需要在…
Windows下跑深度学习模型，遇到‘页面文件太小’报错？别急着加内存条，先试试这个D盘虚拟内存设置（保姆级图文）
Windows深度学习训练遇"页面文件太小"？三步搞定D盘虚拟内存配置刚在本地跑YOLOv8模型训练，突然蹦出个"OSError: [WinError 1455] 页面文件太小"的报错，你是不是也遇到过这种状况？先别急着下单买内存条&#x…
Mac新手必看：绕过‘无法验证开发者’弹窗的3种安全方法（含终端命令详解）
Mac安全指南：理解Gatekeeper机制与灵活管理应用权限刚接触Mac的用户常常会遇到一个令人困惑的弹窗——"无法验证开发者"。这其实是macOS内置的Gatekeeper安全机制在发挥作用。与Windows系统不同，macOS对应用来源有着更严格的管控，这…
机器学习预测钙钛矿薄膜应变弛豫：从稀疏数据挖掘三维弹性耦合机制
1. 项目概述与核心挑战在钙钛矿氧化物这类功能薄膜材料的研究中，外延应变是一个绕不开的核心议题。简单来说，当我们在一种晶体基底上生长另一种材料的薄膜时，由于两者晶格常数不匹配，薄膜的原子排列会被迫“拉伸”或“压缩”以适应…
施工现场安全事故预警准确率达94.6%？——解密某央企AI Agent边缘计算部署架构与3个月落地实录
更多请点击： https://codechina.net 第一章：施工现场安全事故预警准确率达94.6%？——解密某央企AI Agent边缘计算部署架构与3个月落地实录 在华北某大型地铁盾构施工现场，一套轻量化AI Agent系统于2024年Q2完成全栈部署ÿ…
附录 B：术语表
本术语表面向“从 MM 到 HMM”专栏阅读过程中的快速查阅。它不是内核 API 手册，而是把文章中反复出现的概念放到同一张地图上：先给出直观含义，再说明它在 Linux MM/HMM 语境里的作用。建议阅读方式： 初读专栏时，把它当…
Midjourney渐变美学的神经渲染原理（附RGB-HSV-LCH三空间渐变映射对照表·行业首曝）
更多请点击： https://kaifayun.com 第一章：Midjourney渐变美学的神经渲染原理（附RGB-HSV-LCH三空间渐变映射对照表行业首曝） Midjourney 的渐变美学并非传统插值实现，而是由其隐式神经渲染器（Implicit Neu…
施工现场安全事故预警准确率达94.6%？——解密某央企AI Agent边缘计算部署架构与3个月落地实录
更多请点击： https://codechina.net 第一章：施工现场安全事故预警准确率达94.6%？——解密某央企AI Agent边缘计算部署架构与3个月落地实录 在华北某大型地铁盾构施工现场，一套轻量化AI Agent系统于2024年Q2完成全栈部署ÿ…
附录 B：术语表
本术语表面向“从 MM 到 HMM”专栏阅读过程中的快速查阅。它不是内核 API 手册，而是把文章中反复出现的概念放到同一张地图上：先给出直观含义，再说明它在 Linux MM/HMM 语境里的作用。建议阅读方式： 初读专栏时，把它当…
Midjourney渐变美学的神经渲染原理（附RGB-HSV-LCH三空间渐变映射对照表·行业首曝）
更多请点击： https://kaifayun.com 第一章：Midjourney渐变美学的神经渲染原理（附RGB-HSV-LCH三空间渐变映射对照表行业首曝） Midjourney 的渐变美学并非传统插值实现，而是由其隐式神经渲染器（Implicit Neu…
MPC-BE：基于DirectShow架构的专业级开源媒体播放解决方案
MPC-BE：基于DirectShow架构的专业级开源媒体播放解决方案 【免费下载链接】MPC-BE MPC-BE – универсальный проигрыватель аудио и видеофайлов для операционной системы Windows. 项目地址:…
如何快速计算3D模型体积和重量：STL-Volume-Model-Calculator终极指南
如何快速计算3D模型体积和重量：STL-Volume-Model-Calculator终极指南 【免费下载链接】STL-Volume-Model-Calculator STL Volume Model Calculator Python 项目地址: https://gitcode.com/gh_mirrors/st/STL-Volume-Model-Calculator 你是否曾经为3D打印项目…
通过Taotoken CLI工具一键配置团队开发环境与模型密钥
通过Taotoken CLI工具一键配置团队开发环境与模型密钥 1. CLI工具安装与基本使用 Taotoken提供的CLI工具可通过npm全局安装或直接使用npx运行。对于需要频繁使用CLI的团队，推荐全局安装： npm install -g taotoken/taotoken对于临时使用或项目级配置&a…