最近因工作需要,研究了一下zookeeper和kafka,之前接触过一点消息队列的知识,但是没有深入了解过。感觉kafka还是很难啃的,因此找了很多的资料去认识和理解。本篇文章介绍了如何在windows电脑上安装zookeeper和kafka(一般是在linux上安装),方便理解kafka相关命令。
一、首先电脑上要安装好jdk,并且配置好jdk环境变量等。我的是jdk1.8
二、下载zookeeper以及kafka安装包
zookeeper:http://zookeeper.apache.org/releases.html(apache-zookeeper-3.5.5-bin.tar.gz)
kafka:http://kafka.apache.org/downloads.html(kafka_2.11-2.1.1.tgz)
三、安装zookeeper:
(1)解压,D:\software\zookeeper,多出来两个文件,红框已标注
(2)进入到D:\software\zookeeper\apache-zookeeper-3.5.5-bin\conf
复制zoo_sample.cfg,并且修改名称为zoo.cfg,打开zoo.cfg,我是用nodepad++打开的。修改dataDir
dataDir= D://software//kafka//data//logs//zookeeper
新增一个日志记录的目录,并且配置到dataDir中。
(3)配置环境变量
右击我的电脑-》高级系统设置-》环境变量,在系统变量中添加如下配置
变量值:ZOOKEEPER_HOME
变量名:D:\software\zookeeper\apache-zookeeper-3.5.5-bin
=======================================================
变量值:path
变量名:%ZOOKEEPER_HOME%\bin
四、安装配置kafka
(1)解压kafka的压缩包(本文是到D盘D:\software\kafka\kafka_2.11-2.1.1)
(2)新建一个放日志的目录data,(本文D:\software\kafka\kafka_2.11-2.1.1\kafka-logs)
(3)打开kafka的server.properties(D:\software\kafka\kafka_2.11-2.1.1\config目录下)
编辑log.dirs
############################# Log Basics #############################
# A comma separated list of directories under which to store log files
log.dirs=D://software//kafka//kafka_2.11-2.1.1//kafka-logs
(4)配置环境变量
变量名:KAFKA_HOME
变量值:D:\software\kafka\kafka_2.11-2.1.1
==========================================
变量值:path
变量值:%KAFKA_HOME%\bin\windows
五、启动zookeeper(必须先启动zookeeper)
快捷键:win+r,之后输入cmd,回车,打开控制台,输入zkserver
zkserver
输出:
六、启动kafka
重新打开一个cmd窗口,输入下面命令:
kafka-server-start D:\software\kafka\kafka_2.11-2.1.1\config\server.properties
输出:
七、启动生产者,可以输入信息
kafka-console-producer.bat --broker-list localhost:9092 --topic test
八、启动消费者,输出对应topic的信息,如红框所示
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning