当前位置: 首页 > news >正文

Kafka 3.0.0集群部署教程

1、集群规划

主机名

ip地址

node.id

process.roles

kafka1

192.168.0.29

1

broker,controller

Kafka2

192.168.0.30

2

broker,controller

Kafka3

192.168.0.31

3

broker,controller

2、将kafka包上传以上节点/app目录下

mkdir /app

3、解压kafka包 所有节点

tar -zxvf kafka_2.13-3.0.0.tgz

4、修改Raft配置文件

cd kafka_2.13-3.0.0

vi config/kraft/server.properties

192.168.0.29机器配置

process.roles=broker,controller

node.id=1

controller.quorum.voters=1@192.168.0.29:9093,2@192.168.0.30:9093,3@192.168.0.31:9093

listeners=PLAINTEXT://192.168.0.29:9092,CONTROLLER://192.168.0.29:9093

advertised.listeners=PLAINTEXT://192.168.0.29:9092

192.168.0.30机器配置

process.roles=broker,controller

node.id=2

controller.quorum.voters=1@192.168.0.29:9093,2@192.168.0.30:9093,3@192.168.0.31:9093

listeners=PLAINTEXT://192.168.0.30:9092,CONTROLLER://192.168.0.30:9093

advertised.listeners=PLAINTEXT://192.168.0.30:9092

192.168.0.31机器配置

process.roles=broker,controller

node.id=3

controller.quorum.voters=1@192.168.0.29:9093,2@192.168.0.30:9093,3@192.168.0.31:9093

listeners=PLAINTEXT://192.168.0.31:9092,CONTROLLER://192.168.0.31:9093

advertised.listeners=PLAINTEXT://192.168.0.31:9092

5、生成一个唯一的集群ID 第一节点

使用bin目录下的kafka-storage.sh工具为你的新集群生成一个唯一的ID

bin/kafka-storage.sh random-uuid

6、格式化存储数据的目录 所有节点

bin/kafka-storage.sh format -t pdw5bp6oSbCxY59UpqR5Ng -c ./config/kraft/server.properties

meta.properties 文件内容

cat /tmp/kraft-combined-logs/meta.properties

7、开放端口  所有节点

sudo firewall-cmd --state

sudo firewall-cmd --zone=public --add-port=9092/tcp --permanent

sudo firewall-cmd --zone=public --add-port=9093/tcp --permanent

sudo firewall-cmd --reload

sudo firewall-cmd --zone=public --list-ports

8、启动 所有节点

bin/kafka-server-start.sh ./config/kraft/server.properties

http://www.lryc.cn/news/447598.html

相关文章:

  • 昇思MindSpore进阶教程-格式转换
  • 搜索软件 Everything 的安装与使用教程
  • oracle 如何判断当前时间在27号到当月月底
  • Django 配置邮箱服务,实现发送信息到指定邮箱
  • Git使用手册
  • sql-labs靶场
  • 【Redis入门到精通二】Redis核心数据类型(String,Hash)详解
  • 如何快速免费搭建自己的Docker私有镜像源来解决Docker无法拉取镜像的问题(搭建私有镜像源解决群晖Docker获取注册表失败的问题)
  • QT 获取视频帧Opencv获取清晰度
  • 生成式AI如何辅助医药行业智能营销
  • 演示:基于WPF的DrawingVisual开发的Chart图表和表格绘制
  • 汽车保养BBBBBBBBBBB
  • H3C R4900 G3服务器上配置本地磁盘RAID
  • HBase DDL操作代码汇总(namespace+table CRUD操作)
  • 关于TCP的基础知识
  • MyBatis 中的类型别名配置详解
  • 如何提高UI自动化的稳定性
  • ubuntu如何开启和关闭图形界面
  • 从博客到ICT社区:深化学习与交流的桥梁
  • 基于python+django+vue的旅游景点数据分析系统
  • C++简单缓冲区类设计
  • MySQL 数据库
  • 基于单片机的智能校园照明系统
  • 高性能分布式搜索引擎Elasticsearch详解
  • 连锁收银系统的五大功能 选择开源收银系统三要素
  • 虚幻引擎解决构建问题
  • C++基础知识:C++中读文件的四种简单方式
  • 【人工智能】多模态AI:如何通过融合文本、图像与音频重塑智能系统未来
  • 通过重写QStyle控制QT控件样式
  • WPF入门教学十八 动画入门