kafka3.4.0单机版安装配置教程（kraft模式舍弃ZK）_基于kraft方式部署单机版

单机版安装（kraft模式）

文件下载

下载地址：https://archive.apache.org/dist/kafka/3.4.0/

解压文件

tar -zxvf kafka_2.13-3.4.0.tgz
mv kafka_2.13-3.4.0 kafka340
1
2

修改配置文件

#自己的文件目录
cd /opt/kafka340/config/kraft
# 创建数据日志存储文件夹
 mkdir -p /data/logs/kraft-combined-logs
#给文件夹权限
chmod a+rx /data/logs/kraft-combined-logs/
通过命令打开配置文件
vim server.properties

#修改log.dirs=/data/logs/kraft-combined-logs


1
2
3
4
5
6
7
8
9
10
11
12

格式化储存目录

#生成储存目录唯一ID
bin/kafka-storage.sh random-uuid
#控制台输出ZDJX-bKfTcy-BY4e-qmvTg
#用该ID格式化kafka储存目录
bin/kafka-storage.sh format -t ZDJX-bKfTcy-BY4e-qmvTg -c config/kraft/server.properties
#控制台输出Formatting /data/logs/kraft-combined-logs with metadata.version 3.4-IV0.
1
2
3
4
5
6

启动kafka

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

创建kafka主题

bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic topics-test --partitions 1 --replication-factor 1
1

启动生产消费者

# 启动一个生产者发送数据
bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic topics-test
# 启动消费者接收数据
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topics-test

1
2
3
4
5

远程访问设置

vim config/kraft/server.properties
#修改配置，允许监听所有IP的请求,云服务器记得开放安全组端口和防火墙端口
listeners=PLAINTEXT://0.0.0.0:9092,CONTROLLER://:9093

# 开放端口（临时生效）
firewall-cmd --add-port=9092/tcp
# --add-port=9092/tcp：表示要开放TCP协议的9092端口。

# 永久性地开放端口（重启后依然有效）
firewall-cmd --permanent --add-port=9092/tcp
#--permanent：表示这个更改是持久化的，会在系统重启后仍然保留

# 刷新并应用新的防火墙规则
firewall-cmd --reload
# --reload：在进行永久性更改后，需要重新加载防火墙配置以使其生效。

# 验证端口是否已成功添加到防火墙规则中（永久生效部分）
firewall-cmd --list-all --permanent


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20