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配置文件:

Kafka环境的搭建(Windows)
 2.5、运行Zookeeper,进入zookeeper-3.4.9\bin目录,双击zkServer.cmd如果打印以下信息则表示zookeeper已经安装成功并运行在2181端口

Kafka环境的搭建(Windows)

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

Kafka环境的搭建(Windows)

 Kafka环境的搭建(Windows)

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

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

Kafka环境的搭建(Windows)

 

查看主题

.\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

 Kafka环境的搭建(Windows)

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

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

 Kafka环境的搭建(Windows)

5、测试

Kafka环境的搭建(Windows)