有关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启动成功:
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
显示信息如下:
但在命令下完回车时会报如下一个错误,目前不知道什么原因:
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
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下如何删除topics,目前还不清楚,现有的命令只是标记已删除,后续学习中会陆续更新。。。