一：下载安装
三台机器分别安装
cd opt
wget https://dlcdn.apache.org/kafka/3.3.1/kafka_2.13-3.3.1.tgz
tar -zxvf kafka_2.13-3.3.1.tgz
mkdir kraft_log

二：配置文件

1.分别修改三台机器的hostname
hostnamectl set-hostname kraft1
hostnamectl set-hostname kraft2
hostnamectl set-hostname kraft3

2.配置hosts
vim etc/hosts
192.169.88.101 kraft1
192.169.88.102 kraft2
192.169.88.103 kraft3

3.cd /opt/kafka_2.13-3.3.1/config/kraft
vim server.properties

1).配置 kraft1

1.png

2.png

2).配置 kraft2

3.png

4.png

3).配置 kraft3

5.png

6.png

三：防火墙设置
添加端口
firewall-cmd --permanent --zone=public --add-port=9092/tcp
firewall-cmd --permanent --zone=public --add-port=9093/tcp
刷新：firewall-cmd --reload

四：启动集群
1.kraft1

生成集群 UUID
bin/kafka-storage.sh random-uuid
生成的uuid

格式化日志目录
bin/kafka-storage.sh format -t 生成的uuid -c config/kraft/server.properties

启动kafka服务器
bin/kafka-server-start.sh config/kraft/server.properties

2.kraft2

格式化日志目录
bin/kafka-storage.sh format -t kraft1生成的uuid -c config/kraft/server.properties

启动kafka服务器
bin/kafka-server-start.sh config/kraft/server.properties

3.kraft3

格式化日志目录
bin/kafka-storage.sh format -t kraft1生成的uuid -c config/kraft/server.properties

启动kafka服务器
bin/kafka-server-start.sh config/kraft/server.properties

五：测试是否搭建成功

在任意一台服务器创建主题
bin/kafka-topics.sh --create --topic topic1 --bootstrap-server localhost:9092
在任意任何服务器查询
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
bin/kafka-topics.sh --list --bootstrap-server kraft1:9092
bin/kafka-topics.sh --list --bootstrap-server kraft2:9092
bin/kafka-topics.sh --list --bootstrap-server kraft3:9092