windows下kafka环境搭建

时间:2022-12-13 09:07:55

有关kafka的介绍以及linux下kafka环境搭建,可以借鉴Kafka入门经典教程http://www.aboutyun.com/thread-12882-1-1.html,讲的很详细。

因为刚接触,所以对kafka也不是很了解,先做一个简单地环境搭建,往后接触多了,会慢慢在更新。。。

环境搭建

step 1:安装JDK

这步就不多说了,一般情况jdk我们都安装在默认路径:
JAVA_HOME: C:\Program Files\Java\jdk1.8.0_92,
但是在我运行kafka时报错:无法识别Files\Java\jdk1.8.0_92 C:\Program,最后发现是Program Files中间的空格造成,重新更换路径后,启动成功,

step 2:安装Zookeeper

Kafka的运行依赖于Zookeeper,所以在运行Kafka之前我们需要安装并运行Zookeeper。
2.1,下载安装文件: http://zookeeper.apache.org/releases.html

2.2,解压文件(本文解压到 D:\Program Files\zookeeper-3.4.8)

2.3,打开D:\Program Files\zookeeper-3.4.8\conf,zoo_sample.cfg 复制一份并重命名成zoo.cfg,然后编辑此文件

2.4,修改dataDir和dataLogDir保存路径
dataDir=D:/Program Files/zookeeper-3.4.8/data
dataLogDir=D:/Program Files/zookeeper-3.4.8/log

2.5,运行Zookeeper: 在D:\Program Files\zookeeper-3.4.8\bin路径中“Shift+鼠标右键“点击在此处打开命令提示窗口,输入zkserver ,如果打印以下信息,则表示zk启动成功:
windows下kafka环境搭建

step 3:安装并运行Kafka

3.1,下载安装文件: http://kafka.apache.org/downloads.html

3.2,解压文件(本文解压到 D:\kafka_2.11-0.10.0.1)

3.3,打开D:\kafka_2.11-0.10.0.1\config,编辑server.properties

3.4,log.dirs保存路径更改为
log.dirs=D:\kafka_2.11-0.10.0.1\kafka-logs,并创建kafka-logs文件夹

3.5,D:\kafka_2.11-0.10.0.1\bin文件夹下的.sh命令脚本是在shell下运行的,此文件夹下还有个windowswen文件夹,里面是windows下运行的.bat命令脚本

3.6,在D:\kafka_2.11-0.10.0.1文件夹中”Shift+鼠标右键”点击在此处打开命令提示窗口

3.7,输入并执行一下命令以打开kafka:

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

显示信息如下:
windows下kafka环境搭建
但在命令下完回车时会报如下一个错误,目前不知道什么原因:
windows下kafka环境搭建

step 4:创建一个topics

4.1,D:\kafka_2.11-0.10.0.1\bin\windows路径中“Shift+鼠标右键”选择“在此处打开命令窗口”,

kafka-topics.bat –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test1

windows下kafka环境搭建

step 5:创建一个Producer

kafka-console-producer.bat –broker-list localhost:9092 –topic test

step 6:创建一个Consumer

kafka-console-consumer.bat –zookeeper localhost:2181 –topic test

step 7:测试

windows下kafka环境搭建

至于windows下如何删除topics,目前还不清楚,现有的命令只是标记已删除,后续学习中会陆续更新。。。