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消费者