kafka服务端搭建 无zookeeper

前言

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