kafka下载地址：https://kafka.apache.org/downloads

https://archive.apache.org/dist/kafka/3.2.1/kafka_2.13-3.2.1.tgz

启动方式一：在kafka2版本强依赖于zookeeper我们首先启动zk，然后进行启动kafka，

这种启动方式在之后kafka不依赖于zk也可以使用。

 1、编写启动zk启动脚本；

 2、编写kafka启动脚本；

目录结构： 

 3、启动zk： 

4、启动kafka

方式一启动成功！

启动方式二：不依赖于zk直接启动；

 

1、生成唯一标识../bin/kafka-storage.sh random-uuid

 

 

2、./kafka-storage.sh format -t nzeTYg7GSeGOG7aJgZ2cvA -c ../config/kraft/server.properties 

 3、启动kafka命令：./kafka-server-start.sh ../config/kraft/server.properties 

 4、创建主题：./kafka-topics.sh --bootstrap-server localhost:9092 --create --topic xxx-topic --replication-factor 1 --partitions 8

--create: 创建

--topic:主题名称

--replication-factor:

--partitions:分区数量

5、生产消息：./kafka-console-producer.sh --broker-list localhost:9092 --topic xxx-topic 

 

6、消费消息：./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic xxx-topic --from-beginning --consumer.config ../config/consumer.properties