安装JDK,跳过
kafka依赖zookeeper,此处zookeeper安装跳过
http://kafka.apache.org/downloadskafka下载地址
解压文件(我的目录是D:\michal\kafka_2.12-2.1.1)
打开D:\michal\kafka_2.12-2.1.1\config\server.properties文件,把log.dirs修改为【log.dirs=D:\kafka_2.12-0.11.0.0\kafka-logs】
进入kafka文件目录D:\michal\kafka_2.12-2.1.1,执行以下命令,启动kafka通讯的服务器broker
.\bin\windows\kafka-server-start.bat .\config\server.properties
进入kafka文件目录D:\michal\kafka_2.12-2.1.1\bin\windows,创建kafka的消息topics
.\kafka-topics.bat --create --zookeeper 192.168.34.254:2181 --replication-factor 1 --partitions 1 --topic testDemo
分别打开两个cmd窗口,进入目录D:\michal\kafka_2.12-2.1.1\bin\windows,创建Producer和Consumer
.\kafka-console-producer.bat --broker-list localhost:9092 --topic testDemo
.\kafka-console-consumer.bat --zookeeper localhost:2181 --topic testDemo