一、Zookeeper环境配置
（1）.下载zookeeper安装包http://apache.fayea.com/zookeeper/current/；
（2）加压压缩文件到指定位置，本文加压到E:\Kafka\zookeeper-3.4.12，并新建一个文件夹data；
（3）进入到conf目录，复制zoo_sample.cfg为zoo.cfg，修改其中dataDir为新建文件夹data对的路径；
（4）进入bin目录，双击zkServer.cmd即可启动zookeeper。
二、Kafka环境配置
（1）下载Kafka二进制包，http://kafka.apache.org/downloads.html；
（2）解压安装包到指定目录下，这里我们解压到E:\Kafka\kafka_2.11-2.1.0，并新建一个命名为logs的空文件夹；
（3）进入config目录，编辑server.properties 文件，修改 log.dirs 属性部分地址为新建logs文件夹的路径；
（4）在E:\Kafka\kafka_2.11-2.1.0\目录下打开命令窗口，输入如下命令设置CLASSPATH；
SET CLASSPATH=.;
（5）然后输入下面的命令启动kafka-server；
.\bin\windows\kafka-server-start.bat .\config\server.properties
执行结果
（6）测试
- 创建topic：在E:\Kafka\kafka_2.11-2.1.0\bin\windows下打开命令窗口，输入下面的命令创建test主题
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test.topic
- 打开消息生产者：在上一步的命令窗口接着输入
kafka-console-producer.bat --broker-list localhost:9092 --topic test.topic
- 创建一个消息消费者：在E:\Kafka\kafka_2.11-2.1.0\bin\windows下打开命令窗口，输入下面的命令：
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
-
在producer输入内容就会在consumer看到对应显示
