安装zookeeper

地址：zookeeper-3.4.14，下载后解压

  1. 进入zookeeper的相关设置所在的文件目录，例如本文的：D: \ …\zookeeper-3.4.10\conf

  2. 将"zoo_sample.cfg"重命名为"zoo.cfg"

  3. dataDir=/tmp/zookeeper to D:/ …/zookeeper-3.4.10/data

  4. 添加系统环境变量

    • 系统变量中添加ZOOKEEPER_HOME=D:\ …\zookeeper-3.4.10

    • 编辑系统变量中的path变量，增加%ZOOKEEPER_HOME%\bin

安装kafka

地址: kafka-2.11_2.1.1，下载后解压

同样加入到环境变量中

启动kafka

  1. 启动zookeeper

zkserver.cmd

  1. 启动kafka

.\bin\windows\kafka-server-start.bat .\config\server.properties

  1. 申请生产者

.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

  1. 申请消费者

.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning