Kafka + Zookeeper下载安装及使用

1. 下载zookeeper并安装zookeeper

1)下载地址

图1:zookeeper下载版本
图2:zookeeper下载地址

2)解压两次,最好在D盘目录,使用好一点的解压软件(亲测自带解压软件有问题),本人使用7-zip解压

图3:zookeeper解压后结果

3)进入目录D:\zookeeper\apache-zookeeper-3.7.0-bin\apache-zookeeper-3.7.0-bin\conf,把zoo_sample.cfg重命名成zoo.cfg

图4:zookeeper配置文件修改

4)将zookeeper添加到环境变量

图5:系统变量添加zookeeper
图6:环境变量添加zookeeper

5)启动zookeeper

       双击zkServer.cmd

图7:启动zookeeper
图8:启动zookeeper成功

2. 下载kafka并安装kafka

1)下载地址

图9:下载kafka

本人下载的版本是https://downloads.apache.org/kafka/2.8.0/kafka_2.12-2.8.0.tgz

2)解压压缩文件,还是解压两次,最好使用好一点的解压工具,解压完成,可以将文件夹复制出来到D盘目录

图10:解压好的kafka

3)修改配置文件

图11:修改server.properties文件

4)启动kafka

打开cmd,进入目录D:\kafka_2.12-2.8.0,执行.\bin\windows\kafka-server-start.bat .\config\server.properties

图12:kafka启动成功

3.测试demo

1)在zookeeper和kafka启动后不要关闭,进入kafka的windows目录执行以下命令,kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic demo

2181是zookeeper端口

图13:测试创建topic

2)再启动两个窗口,一个是消费者,一个是生产者

进入到kafka的windows目录下执行以下命令

生产者:kafka-console-producer.bat --broker-list localhost:9092 --topic demo2

在命令行输入123测试,

消费者:kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic demo2 --from-beginning

在接收处显示123.

注意:总共要起四个服务,zookeeper、kafka、kafka生产者、kafka消费者

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容