一:下载安装
三台机器分别安装
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
2).配置 kraft2
3).配置 kraft3
三:防火墙设置
添加端口
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