1.需要环境

kafka3.3.1需要的环境jdk11或者jdk17

2.安装kafka3.3.1及解压

sudo wget https://downloads.apache.org/kafka/3.3.1/kafka_2.12-3.3.1.tgz
#解压安装包
tar -xzvf kafka_2.12-3.3.1.tgz -C /opt/

3.配置kafka

kafka3.3.1要想使用kraft启动就要进入到 /config/kraft/server.properties中进行更改配置,我这里只配置了单个节点

node.id=1
process.roles=broker,controller
listeners=PLAINTEXT://data-vm1:9092,CONTROLLER://data-vm1:9093
advertised.listeners=PLAINTEXT://127.0.0.1:9092
log.dirs=/data/kraft-combined-logs

4.格式化目录（必须，否则启动报错）

在 /opt/kafka3.3.1目录下执行 ./bin/kafka-storage.sh random-uuid生成唯一的uuid

./bin/kafka-storage.sh format -t （唯一的uuid） -c /opt/kafka3.3.1/config/kraft/server.properties

启动

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

后台启动：

创建 kafka_start.sh脚本,这里将生成uuid的写在脚本里面 但是只需要格式化一边即可

#!/bin/bash
echo start Zookeeper&&kafkaServer !!!
export JAVA_HOME=/opt/jdk-17.0.5
cd /opt/kafka3.3.1
./bin/kafka-storage.sh format -t （唯一uuid） -c /opt/kafka3.3.1/config/kraft/server.properties
./bin/kafka-server-start.sh ./config/kraft/server.properties

创建 kafka_stop.sh脚本（结束脚本，是用之前的kafka的脚本）

#!/bin/bash
#echo stop Zookeeper&&kafkaServer !!!
ps -ef | grep zookeeper |grep -v grep|awk {print $2} | xargs kill -9

对开始结束脚本加上执行权限

chmod u+x kafka_start.sh,chmod u+x kafka_stop.sh

ok,大功告成！！！！！！！！！！！