目录

下载地址

启动

启动zookeeper

启动kafka

队列操作

创建消息队列名

删除消息队列名

查看所有的队列

测试

生产测试

消费测试

---

下载地址

Apache KafkaApache Kafka: A Distributed Streaming Platform.https://kafka.apache.org/downloadswindows下kafka3.0版本的存在bug，当然linux的没有问题。

启动

 

 进入该目录后，在文件路径上输入cmd打开命令提示符。

启动zookeeper

输入

zookeeper-server-start.bat ..\..\config\zookeeper.properties

默认端口：2181

启动kafka

kafka-server-start.bat ..\..\config\server.properties

默认端口：9092

队列操作

创建消息队列名

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic 队列名

删除消息队列名

kafka-topics.bat --delete --zookeeper localhost:2181 --topic 队列名

查看所有的队列

kafka-topics.bat --zookeeper 127.0.0.1:2181 --list

测试

在windows目录下打开两个命令提示符界面，一个作为生产消息的，一个作为消费消息的。就是这两个批处理命令。

生产测试

kafka-console-producer.bat --broker-list localhost:9092 --topic 队列名

消费测试

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic 队列名 --from-beginning