安装zookeeper
kafka运行需要有jdk+zookeeper环境才能够使用,jdk的安装和环境变量的配置就不介绍了,这里需要先安装zookeeper.可以从官网上下载https://www.apache.org/dyn/closer.cgi/zookeeper/
- 将下载下来的包解压一下,然后在conf目录下将zoo_sample.cfg改成zoo.cfg,如图
- 之后打开zoo.cfg将里面的dataDir的路径改一下,我这里修改成下面的
dataDir=E:\\data\\logs\\zookeeper
- 之后把zookeeper配到环境变量里面,它的配置和jdk的配置类似
- 运行zookeeper,在cmd里面输入zkserver会出现下面的就便是安装成功
安装kafka
kafka:http://kafka.apache.org/downloads
- 将下载下来的安装包解压,并进入到conf目录下面找到server.properties文件
- 找到并编辑
log.dirs=E:\\data\\logs\\kafkazookeeper.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
- 之后可以在生产者那个窗口随意输入一些信息,之后就能在消费者那边看到输入的信息
原文地址:https://www.cnblogs.com/zhuguangzhe/p/9283591.html
时间: 2024-10-23 19:07:41