基于kraft启动kafka,无需部署zookeeper

开始前请自行准备好kafka的安装包

1.准备java环境

yum install java-1.8.0-openjdk

或手动离线安装jdk

2.解压kafka

cd /data/software

tar -zxvf kafka_2.12-3.7.0.gz

3.将kafka解压后文件夹重命名为kafka

mv kafka_2.12-3.7.0 kafka

cd kafka

4.以kraft方式启动kafka(无需部署zookeeper)

修改配置文件:

vi ./config/kraft/server.properties

listeners=PLAINTEXT://0.0.0.0:9092,CONTROLLER://0.0.0.0:9093

advertised.listeners=PLAINTEXT://本机ip:9092

log.dirs=/data/software/kafka/config/kraft/kraft-combined-logs

初始化:

./bin/kafka-storage.sh random-uuid
#比如这里得到StM9gr5wSECbVe_S_K3V0w

./bin/kafka-storage.sh format -t xxxx -c ./config/kraft/server.properties
#将此处的xxxx替换为为上一步得到的StM9gr5wSECbVe_S_K3V0w

#--------------------------------------------

#如果上述命令报错,可尝试执行下面的命令
#./bin/kafka-run-class.sh kafka.tools.StorageTool random-uuid
#得到StM9gr5wSECbVe_S_K3V0w

#./bin/kafka-run-class.sh kafka.tools.StorageTool format -t xxxx -c ./config/kraft/server.properties
#将此处的xxxx替换为为上一步得到的StM9gr5wSECbVe_S_K3V0w

5.启动

nohup /data/software/kafka/bin/kafka-server-start.sh /data/software/kafka/config/kraft/server.properties &