前言
kafka2.8以后得版本可以不依赖zookeeper搭建kafka集群，
本文选用kafka3.3.1版本搭建kafka服务端，
搭建环境：CentOS 7、JDK17
无JDK环境参考搭建：https://blog.51cto.com/u_12141297/6114634
一、下载kafka
1、下载地址：https://kafka.apache.org/downloads
2、创建目录
mkdir /usr/local/kafka可以通过SCP,FTP,MobaXterm等工具可以将下载的kafka压缩包上传到虚拟机中。这里我使用MobaXterm
3、解压
cd /usr/local/kafka
tar -zxvf kafka_2.12-3.3.1.tgz
ll
二、启动kafka
#进入解压后的目录
cd kafka_2.12-3.3.1
#生成uuid
./bin/kafka-storage.sh random-uuid
将uuid写入配置文件中 ./bin/kafka-storage.sh format -t 填写生成的uuid -c ./config/kraft/server.properties
启动命令 ./bin/kafka-server-start.sh ./config/kraft/server.properties
如果需要后台启动./bin/kafka-server-start.sh ./config/kraft/server.properties &
创建topic的命令bin/kafka-topics.sh --create --topic myfirsttopic --partitions 1 --replication-factor 1 --bootstrap-server localhost:9092
创建生产者的命令bin/kafka-console-producer.sh --broker-list localhost:9092 --topic myfirsttopic
创建消费者的命令bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic myfirsttopic --from-beginning
