真的是难为我了 有坑！
一定要注意命令有些地方的空格该不该有！
一、准备工作
下载kafka，去阿帕奇官网直接下载就好了
然后jdk也要部署在环境里
zookeeper不知道需不需要部署，反正我是部署上去了，跟部署环境变量一样的操作
二、运行和测试
注意：在启动Kafka前，先运行Zookeeper实例。 (前面的cmd命令:zkserver)
在windows下运行 zookeeper-server-start.bat ../../config/zookeeper.properties
成功了就是这样子
①启动Kafka服务器
新建cmd窗口:
cd D:\Tool\kafka_2.11-2.1.1 (此处自己所在文件夹下)
.\bin\windows\kafka-server-start.bat .\config\server.properties
②创建主题
新建cmd窗口:
cd D:\Tool\kafka_2.11-2.1.1\bin\windows
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kk
这样就创建好主题了。
③创建生产者
新建cmd窗口:
cd D:\Tool\kafka_2.11-2.1.1\bin\windows
kafka-console-producer.bat --broker-list localhost:9092 --topic kk
④创建消费者
新建cmd窗口:
cd D:\Tool\kafka_2.11-2.1.1\bin\windows
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kk --from-beginning
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
⑤生产消息并消费
以下就完成了
一切截图本人亲测！完工！
给自己加个鸡腿！