1 安装JDK

1.1 官网下载Java SE Runtime Environment：

      http://www.oracle.com/technetwork/java/javase/downloads/jre8-downloads-2133155.html

1.2 配置电脑环境变量：

    （1） 右键点击“我的电脑” -> “属性”->”高级系统设置” -> “环境变量”。

    （2）设置JAVA_HOME: C:\Program Files\Java\jre1.8.0_131（此为默认安装路径，以实际安装路径为准），修改PATH: 在现有的值后面添加”; %JAVA_HOME%\bin”（注意分号）。

 1.3 运行cmd，执行”java -version”，查看当前已安装Java版本，验证安装是否成功。

2 Kafka的运行依赖于Zookeeper，故需要安装并运行Zookeeper

2.1 下载安装文件： http://www.apache.org/dyn/closer.cgi/zookeeper/

2.2 解压文件（本文解压到 C:\zookeeper-3.4.10）

2.3 打开C:\zookeeper-3.4.10\conf，备份zoo_sample.cfg，然后重命名为zoo.cfg

2.4 打开zoo.cfg

      设置dataDir=/zookeeper/data

2.5 添加如下系统变量：

      ZOOKEEPER_HOME: C:\zookeeper-3.4.10

      Path: 在现有的值后面添加 “;%ZOOKEEPER_HOME%\bin;”

2.6 运行Zookeeper: 打开cmd然后执行：

      zkserver

启动Zookeeper也可以去接下来介绍的Kafka内进行zookeeper.properties文件的配置和zookeeper-server-start.bat文件的启动。

3 安装并运行Kafka

3.1 下载安装文件：http://kafka.apache.org/downloads.html

3.2 解压文件（本文解压到 C:\kafka_2.12-0.11.0.0）

3.3 打开C:\kafka_2.12-0.11.0.0\config

3.4 从文本编辑器里打开 server.properties

3.5 修改配置参数：

      第34行 listeners=PLAINTEXT://127.0.0.1:9092；

      第63行 log.dirs=C:/kafka_2.12-0.11.0.0/kafka-logs；

      第126行 zookeeper.connect=127.0.0.1:2181；

3.6 打开cmd

3.7 进入kafka文件目录: cd  C:\kafka_2.12-0.11.0.0

3.8 输入并执行以打开kafka:

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

4 创建topics

4.1 通过Cmd进入C:\kafka_2.12-0.11.0.0\bin\windows

4.2 创建topic

     kafka-topics.bat –create –zookeeper 127.0.0.1:2181 –replication-factor 1 –partitions 1 –topic test

     查看所有topic

     kafka-topics.bat –list –zookeeper 127.0.0.1:2181

5. 开启Producer

     打开一个cmd窗口，执行以下操作：

      cd  C:\kafka_2.12-0.11.0.0\bin\windows

      kafka-console-producer.bat –broker-list 127.0.0.1:9092 –topic test

6. 开启Consumer，监视Producer

    打开一个cmd窗口，执行以下操作：

      cd  C:\kafka_2.12-0.11.0.0\bin\windows

      kafka-console-consumer.bat –zookeeper 127.0.0.1:2181 –topic test

当在producer窗口输入内容时，可以在consumer窗口看到收到的内容。