- 下载kafka，官方地址https://kafka.apache.org/downloads
百度网盘链接：https://pan.baidu.com/s/1h3iXtfzEIBoajGPId5Dcag?pwd=0000
提取码：0000 - 直接把下载的文件解压到某个盘的根目录，要不然后面的命令就会遇到“命令行过长”的报错；
- kafka需要java的支持，所以你的本地环境还得支持java环境；
- 进入解压好的kafka_2.13-3.4.0目录，配置两个文件
config/server.properties
zookeeper.properties
# server.properties 34 行
listeners=PLAINTEXT://localhost:9092
# server.properties 62 行
log.dirs=./logs
# zookeeper.properties 16 行，对应kafka的根目录新建data文件夹
dataDir=./data
- 开始运行kafaka服务，进入kafka_2.13-3.4.0目录cmd
5.1、启动zookeeper
# 启动zookeeper
.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties
保持窗口不要关闭
5.2、启动kafka-server，重复第一步打开的新的cmd窗口
# 启动kafka-server
.\bin\windows\kafka-server-start.bat .\config\server.properties
保持窗口不要关闭
5.3、启动kafka-topics，重复第一步打开的新的cmd窗口
# 创建一个名为test的topic
.\bin\windows\kafka-topics.bat --create --bootstrap-server localhost:2181 --replication-factor 1 --partitions 1 --topic test
启动之后，kafka-topics处于等待创建topic状态，一段时间内如果不createTopic，kafka-topics将自动断开。
5.4、启动消费者，重复第一步打开的新的cmd窗口
# 启动消费者，并接受test的队列消息
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test
5.5、启动生产者，重复第一步打开的新的cmd窗口
# 启动生产者，重复第一步打开的新的cmd窗口
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
此时，就可以在控制台界面输入字符串，回车，对应的消费者控制台就能实时的显示对应的值。
