1、启动zookeeper:先启动cmd运行zkserver运行起来后窗口不能关闭
2、启动zookeeper:然后在kafka文件路径上运行cmd然后执行命令.\bin\windows\zookeeper-server-start.bat config\zookeeper.properties
3、启动kafka: .\bin\windows\kafka-server-start.bat config\server.properties
4、切换到C:\kafka_2.13-2.8.0\bin\windows路径运行CMD
5、创建生产者:kafka-console-producer.bat -broker-list localhost:9092 -topic test
6、创建消费者:kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
生产者输入消息。消费者就能接收到
注:有时候第二部启动失败是因为第一部没启动。测试时候窗口关闭了不懂为啥1,2步骤启动顺序经常出现异常。可能是哪里没有正常关闭导致的。(待研究)
原文:https://www.cnblogs.com/liziqiang/p/14808528.html