Windows下Kafka环境搭建

一、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看到对应显示