Windows上搭建Kafka

搭建环境：

　　1，安装JDK

　　　　JAVA_HOME: C:Program Files (x86)Javajre1.8.0_60（这个是默认安装路径，如果安装过程中更改了安装目录，把更改后的路径填上就行了）

　　　　PATH: 在现有的值后面添加"; %JAVA_HOME%in"

　　　　安装完成后打开cmd 运行“Java -version”查看当前JDK的版本，一般情况下1.7比较适用。

　　2.安装zookeeper

　　　　在运行Kafka之前我们需要先运行Zookeeper

　　2.1 下载安装文件： http://zookeeper.apache.org/releases.html

　　2.2 解压文件（本文解压到 D:zookeeper-3.4.8）目录如图：

　　 2.3 打开D:zookeeper-3.4.8conf，把zoo_sample.cfg重命名成zoo.cfg

　　 2.4 从文本编辑器里打开zoo.cfg

　　2.5 把dataDir的值改成“D:\data\zookeeper”

　　2.6 添加如下系统变量：

　　　　ZOOKEEPER_HOME: D:zookeeper-3.4.8

　　　　Path: 在现有的值后面添加 ";%ZOOKEEPER_HOME%in;"

　　2.7 在D:zookeeper-3.4.8in目录下运行zkServer.cmd

　　有如下显示的话说明安装Zookeeper成功：

　　3.安装kafka

　　　　3.1 下载安装文件： http://kafka.apache.org/downloads.html
　　　　3.2 解压文件（本文解压到 D:kafka_2.11-0.10.0.1）
　　　　3.3 打开G:kafka_2.11-0.10.0.1config
　　　　3.4 从文本编辑器里打开 server.properties
　　　　3.5 把 log.dirs的值改成 “D:kafka_2.11-0.10.0.1kafkaLogs”
　　　　3.6 打开cmd 在kafka存放目录下，打开命令执行框
　　　　3.7 输入
　　　　　　.inwindowskafka-server-start.bat .configserver.properties

　　4.创建topics
　　　　4.1 打开cmd 并进入D:kafka_2.11-0.10.0.1inwindows
　　　　4.2 创建一个topic：
　　　　kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
　　5. 打开一个Producer：
　　　　cd /d D:kafka_2.11-0.10.0.1inwindows
　　　　kafka-console-producer.bat --broker-list localhost:9092 --topic test
　　6. 打开一个Consumer:
　　　　cd /d G:kafka_2.11-0.10.0.1inwindows
　　　　kafka-console-consumer.bat --zookeeper localhost:2181 --topic test
　　　　此时，在创建的Producer中发送信息后，在Consumer框可以接收到。说明Kafka安装部署已经完成。