kafka3.4.0单机版安装配置教程（kraft模式舍弃ZK）

单机版安装（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

修改配置文件

#自己的文件目录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

格式化储存目录

#生成储存目录唯一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.

启动kafka

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

创建kafka主题

bin/kafka-topics.sh --bootstrap-server localhost:9092 --create--topic topics-test --partitions1 --replication-factor 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

远程访问设置

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