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

Kafka-Kraft

news 2025/8/21 11:59:27

Kraft集群部署

解压缩kafka后，进入config下的kraft目录

编辑server.properties

每个节点的node.id不能相同

在这里插入图片描述
修改之后如下：

在这里插入图片描述

修改advertised.listeners=PLAINTEXT://localhost:9092为本机IP地址

在这里插入图片描述

修改log.dirs

在这里插入图片描述

配置完成后分发到其他节点

分发完成后，更改各自配置

slave1节点
在这里插入图片描述

slave2节点：

在这里插入图片描述

初始化集群数据目录

首先生成存储目录唯一ID

bin/kafka-storage.sh random-uuid

在这里插入图片描述

用该ID格式化kafka存储目录（三台节点）

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

在这里插入图片描述

启动集群

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

在这里插入图片描述

测试：

创建主题：

bin/kafka-topics.sh --bootstrap-server master:9092 --create --topic first --partitions 3 --replication-factor 3

在这里插入图片描述

查看：

在这里插入图片描述

Kraft集群启动停止脚本

#!/bin/bash
case $1 in
"start")for i in master slave1 slave2doecho "--- 启动 $i kafka ---"ssh $i "/usr/local/soft/kraftKafka/kafka/bin/kafka-server-start.sh -daemon /usr/local/soft/kraftKafka/kafka/config/kraft/server.properties"done
;;
"stop")for i in master slave1 slave2doecho "--- 停止 $i kafka ---"ssh $i "/usr/local/soft/kraftKafka/kafka/bin/kafka-server-stop.sh"done
;;
esac