热衷学习，热衷生活！😄

沉淀、分享、成长，让自己和他人都能有所收获！😄

1. 先下载并启动zookeeper（启动窗口不能关闭）
2. 下载kafka：http://kafka.apache.org/downloads.html （注意下载binary版本的，不要下载3.0版本的，3.0windows下有问题，启动报错，换成2.8就没问题）
3. 解压到相应文件夹，进入config目录下，找到server.properties文件，并作以下修改：

　　找到并编辑 log.dirs=D:\soft\kafka\kafka_2.13-2.8.0\kafka-logs (kafka的解压目录，kafka-logs文件夹不用自己新建)

　　找到并编辑zookeeper.connect=localhost:2181 （一般默认就是localhost:2181）

4. 打开命令命令进到kafka目录，输入下面命令启动kakfa（窗口不能关闭）
1
.\bin\windows\kafka-server-start.bat .\config\server.properties
5. 测试
1）打开一个新的命令窗口，输入下面命令创建主题，提示Created topic 主题名则表示成功
1
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
2）查看已经创建的主题命令：
1
.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
3）打开一个新的命令窗口，创建生产者，输入以下命令，创建完毕之后可以输入 hello world消息
1
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
4）打开一个新的命令窗口，创建消费者，输入以下命令，可以看到消费了hello world消息
1
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning