单机版安装（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。#kafka存储目录采用ID格式化。bin/kafka-storage.sh。 format。-t。ZDJX-bKfTcy-BY4e-qmvTg。 -c。config/kraft/server.properties。#控制台输出Formating /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。 --partitions。1。--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。# 开放端口（临时生效）#xff0;firewall-cmd --add-port。=9092。/tcp。# --add-port=9092/tcp：9092端口表示将打开TCP协议。# 永久开放端口（重启后仍然有效）firewall-cmd。 --permanent。--add-port。=9092。/tcp。#--permanent：这意味着这种变化是持久的，系统重启后仍将保留。# 刷新并应用新的防火墙规则。firewall-cmd。 --reload。# --reload：永久性变更后，防火墙配置需要重新加载才能生效。# 验证端口是否成功添加到防火墙规则中（永久生效部分）firewall-cmd --list-all。 --permanent。