Kafka环境的搭建(Windows）

1、安装JDK

2、安装Zookeeper 
Kafka的运行依赖于Zookeeper，所以在运行Kafka之前我们需要安装并运行Zookeeper 
 2.1、下载安装文件（zookeeper-3.4.9）： http://mirror.bit.edu.cn/apache/zookeeper/
 2.2、解压zookeeper-3.4.9（解压到 E:\develop\Kafka\zookeeper-3.4.9） 
 2.3、打开zookeeper-3.4.9\conf，把zoo_sample.cfg重命名成zoo.cfg 
 2.4、修改zoo.cfg配置文件：

 2.5、运行Zookeeper，进入zookeeper-3.4.9\bin目录，双击zkServer.cmd如果打印以下信息则表示zookeeper已经安装成功并运行在2181端口

3、安装Kafka

 3.1、Kafka下载地址http://kafka.apache.org/downloads.html，下载后解压到E:\develop\Kafka\kafka_2.12-1.0.0

 3.2、配置server.properties文件（E:\develop\Kafka\kafka_2.12-1.0.0\config\server.properties），Kafka会按照默认，

在9092端口上运行，并连接zookeeper的默认端口：2181
   3.2.1、log.dirs=E:/develop/Kafka/kafka_2.12-1.0.0/tmp/kafka-logs
   3.2.2、zookeeper.connect=localhost:2181
4、启动Kafka(启动Kafka服务器前，确保Zookeeper实例已经准备好并开始运行)

 4.1、启动服务端，进行cmd命令窗口，启动成功后不要关闭窗口

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

 

4.2、创建主题，进行cmd命令窗口，创建成功后不要关闭窗口

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kftest01 

 

查看主题

.\bin\windows\kafka-topics.bat -zookeeper localhost:2181 --list kftest01
删除主题

.\bin\windows\kafka-topics.bat --delete --zookeeper localhost:2181 --topic kftest01 Topic kf_test_01 is marked for deletion. Note: This will have no impact if delete.topic.enable is not set to true.

4.3、创建生产者，进行cmd命令窗口，创建成功后不要关闭窗口

.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic kftest01

 

4.4、创建消费者，进行cmd命令窗口，创建成功后不要关闭窗口

.\bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic kftest01

 

5、测试