安装zookeeper
kafka运行需要有jdk+zookeeper环境才能够使用,jdk的安装和环境变量的配置就不介绍了,这里需要先安装zookeeper.可以从官网上下载
https://www.apache.org/dyn/closer.cgi/zookeeper/
清华镜像：https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/
-
将下载下来的包解压一下,然后在conf目录下将zoo_sample.cfg改成zoo.cfg,如图
-
之后打开zoo.cfg将里面的dataDir的路径改一下,我这里修改成下面的
dataDir=E:\\Software\\data\\logs\\zookeeper
-
之后把zookeeper配到环境变量里面,它的配置和jdk的配置类似
-
运行zookeeper,在cmd里面输入zkserver会出现下面的就便是安装成功
-
安装kafka
kafka:http://kafka.apache.org/downloads
清华镜像：https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/
-
将下载下来的安装包解压,并进入到conf目录下面找到server.properties文件
-
找到并编辑
log.dirs=E:\\Software\\data\\logs\\kafka
zookeeper.connect=localhost:2181 -
之后进入到kafka的目录下执行下面的命令,可以使用在文件夹的空白处按着shift加鼠标右键打开命令窗口
.\bin\windows\kafka-server-start.bat .\config\server.properties
!每次运行kafka的时候都要把这个和上面的zkserver开启 -
之后可以测试一下创建一个主题
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
-
之后开启生产者,进入到bin/windows目录下使用命令窗口
.\kafka-console-producer.bat --broker-list localhost:9092 --topic test
-
开启消费者,进入到bin/windows目录下使用命令窗口
.\kafka-console-consumer.bat --zookeeper localhost:2181 --topic test
-
之后可以在生产者那个窗口随意输入一些信息,之后就能在消费者那边看到输入的信息
