在windows下搭建Kafka环境

1.从官方网站上分别下载zookeeper和kafka的压缩包

kafka：http://kafka.apache.org/downloads

zookeeper:http://kafka.apache.org/downloads.html

 

2.把下载下来的kafka和zookeeper分别解压缩到自己的盘符上这里我解压到了d盘：

 

3.配置相关的环境变量，这里需要配置一下zookeeper的环境变量

接着打开zookeeper的conf文件夹，将zoo_sample.cfg复制一份重命名为zoo.cfg,

并修改如下内容，保存：

dataDir=D:/zookeeper-3.4.12/data

修改kafka的conf文件夹下面的server.properties文件：

log.dirs=D:/kafka_2.11-1.1.0/kafka-logs

 

4.打开控制台启动zookeeper的服务：

zkserver

 

启动kafka服务：

D:\kafka_2.11-1.1.0\bin\windows>kafka-server-start.bat ../../config/server.properties

5. 创建一个topic：

D:\kafka_2.11-1.1.0\bin\windows>kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

6.创建一个producer:

D:\kafka_2.11-1.1.0\bin\windows>kafka-console-producer.bat --broker-list localhost:9092 --topic test

7.创建一个customer：

D:\kafka_2.11-1.1.0\bin\windows>kafka-console-consumer.bat --zookeeper localhost:2181 --topic test

 

8.测试kafka环境：