1. 下载Kafka 2.10安装包

下载Kafka 2.10压缩包，下载地址: https://www.apache.org/dyn/closer.cgi?path=/kafka/2.1.0/kafka_2.11-2.1.0.tgz

解压安装包到任意目录，我的解压位置：C:\Develop\kafka_2.11-2.1.0

2. 启动ZooKeeper服务

Kafka依赖于ZooKeeper，因此我们需要首先启动ZooKeeper。Kafka 2.10版本已经继承了ZooKeeper服务，在启动ZooKeeper前，先修改ZooKeeper的配置文件。

打开配置文件：C:\Develop\kafka_2.11-2.1.0\config\zookeeper.properties，修改配置项：dataDir的值。我的配置如下：

dataDir=C:\Develop\kafka_2.11-2.1.0\zookeeper

打开一个命令行窗口，运行以下命令启动ZooKeeper服务：

cd C:\Develop\kafka_2.11-2.1.0
bin\windows\zookeeper-server-start.bat config\zookeeper.properties

3. 启动Kafka服务

启动Kafka服务前，在Windows环境下我们也需要修改默认的配置项。打开配置文件：C:\Develop\kafka_2.11-2.1.0\config\server.properties，修改配置项：log.dirs的值。我的配置如下：

log.dirs=C:\Develop\kafka_2.11-2.1.0\kafka-logs

打开一个命令行窗口，运行以下命令启动Kafka服务：

cd C:\Develop\kafka_2.11-2.1.0
bin\windows\kafka-server-start.bat config\server.properties

4. 测试运行之创建topic

至此，Kafka服务已经运行。下面我们创建一个topic来测试Kafka服务是否运行正常。

打开一个命令行窗口，运行以下命令启动创建一个名为test的topic：

cd C:\Develop\kafka_2.11-2.1.0
bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

5. 测试运行之创建producer

创建了一个topic后，下面我们创建一个producer来向这个topic发送消息。

打开一个命令行窗口，运行以下命令启动创建一个producer：

cd C:\Develop\kafka_2.11-2.1.0
bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

这个console producer创建成功后，我们就可以通过控制台输入任意字符串，并按下回车键就实现了消息的发送。

6. 测试运行之创建consumer

拥有了producer之后，下面我们创建一个consumer来消费producer发送的消息。

打开一个命令行窗口，运行以下命令启动创建一个producer：

cd C:\Develop\kafka_2.11-2.1.0
bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

这儿没有指定特定的consumer group，是因为kafka console consumer会自动生成一个随机的group id。因此，每一个kafka console consumer均属于不同的consumer group。consumer group可以通过bin\windows\kafka-consumer-groups.bat --list --bootstrap-server localhost:9092命令进行查看。

7. 测试运行

在producer窗口中输入任意字符串，并按下回车键发送。此时，consumer窗口出现producer发送的消息，消息消费成功。