windows下手把手教你搭建Kafka环境

1：环境搭建

1.1：Java环境搭建

1)JDK下载：jdk官方

注意:最好下载8及以下版本(后面答疑)。

2)设置Java_home

3)设置path

%JAVA_HOME%\bin;%JAVA_HOME%\jre\bin;

4)设置CLASSPATH

“.;JAVA_HOME%\lib\dt.jar;%JAVA_HOME%\LIB\TOOLS.JAR;”(复制双引号里面的语句，注意前面有个.)

5）环境测试

好了以上就完成了java环境的设置。

1.2 ：安装Zookeeper

1)zookeeper安装:zookeeper-3.4.14

(我选的3.4.14版本)。

2)解压

下载后，解压放在自己想要安装的目录下，路径中最好不要出现空格，比如C:\Program Files，C:\Program Files (x86)尽量别用，不然在后面运行脚本时会发生错误。(本文文件夹路径为：C:\zookeeper)

3)环境配置

1. 创建ZOOKEEPER_HOME
   
   2.在PATH后添加“%ZOOKEEPER_HOME%\bin;”(复制双引号里面的语句)
   

4)修改文件

1.进入zookeeper的相关所在的文件目录，例如本文的：C:\zookeeper\zookeeper-3.4.14\conf
2.将"zoo_sample.cfg"重命名为"zoo.cfg"
3.打开zoo.cfg(就是你刚刚重命名的文件夹)
4.找到 dataDir=/tmp/zookeeper 修改为 dataDir=./zookeeper-3.4.14/data(仅供参考)
5.修改端口(默认为2181，此操作非必要)

5)环境测试

打开CMD，输入“zkserver”(复制双引号里面的内容)。 本窗口不要关(或者等下测试你再输入一次也可以)


以上结果(参考),说明配置成功。

1.3：安装kafka

1)下载:Kafka官方

(本文下载的是kafka_2.11-0.11.0.2.tgz)

2)解压

下载后，解压放在自己想要安装的目录下，路径中最好不要出现空格，比如C:\Program Files，C:\Program Files (x86)尽量别用，不然在后面运行脚本时会发生错误。(本文文件夹路径为：C:\kafka)

3)修改文件

1.进入Kafka的相关所在的文件目录，例如本文的：C:\kafka\kafka_2.11-0.11.0.2\config
2.打开server.properties
4.找到 将log.dirs=/tmp/kafka-logs的值改成log.dirs=./logs(仅供参考)

4)启动Kafka

打开cmd输入以下指令
1.“cd C:\kafka\kafka_2.11-0.11.0.2”(参考，这是你下载的文件夹路径，表示进入该文件夹)
2.".\bin\windows\kafka-server-start.bat .\config\server.properties"（复制双引号里面的内容）
本窗口不要关(或者等下测试你再输入一次也可以)

启动成功界面：

启动失败界面：

原因如下：
1)jdk版本过高，要8及8以下版本，高版本没有DatatypeXonverter该类(对本文开头下载JDK版本要求的解释)。

2：Kafka测试

2.1：创建Topic

1.新建cmd窗口 本窗口不要关
2.输入“cd /d C:\kafka\kafka_2.11-0.11.0.2\bin\windows”(仅供参考)
3.输入“kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test”(复制双引号里面的内容)
4.结果展示 success or fail

4.1创建成功

这样一个名为test的topic创建成功

4.2创建失败

原因：1)Kafka启动失败.(参考1.3Kafka的启动)

2.2：创建producer

1.新建CMD窗口 本窗口不要关
2.输入"cd /d C:\kafka\kafka_2.11-0.11.0.2\bin\windows"(仅供参考）
3.输入“kafka-console-consumer.bat --zookeeper localhost:2181 --topic test”(复制双引号里面的内容)
4.输入你要产生的消息（随意） 现在先不产生消息

2.3：创建consumer

1.新建CMD窗口 本窗口不要关
2.输入"cd /d C:\kafka\kafka_2.11-0.11.0.2\bin\windows"(仅供参考）
3.输入“kafka-console-consumer.bat --zookeeper localhost:2181 --topic test”(复制双引号里面的内容)

2.4：产生消息

实例如下：
产生消息的CMD窗口(producer)

消费消息的CMD窗口(consumer)

好了以上就完成了window环境下kafka的搭建，如果你觉得写的不错，给个赞吧。^ ^!