1. 下载zookeeper并安装zookeeper
1)下载地址
2)解压两次,最好在D盘目录,使用好一点的解压软件(亲测自带解压软件有问题),本人使用7-zip解压
3)进入目录D:\zookeeper\apache-zookeeper-3.7.0-bin\apache-zookeeper-3.7.0-bin\conf,把zoo_sample.cfg重命名成zoo.cfg
4)将zookeeper添加到环境变量
5)启动zookeeper
双击zkServer.cmd
2. 下载kafka并安装kafka
1)下载地址
本人下载的版本是https://downloads.apache.org/kafka/2.8.0/kafka_2.12-2.8.0.tgz
2)解压压缩文件,还是解压两次,最好使用好一点的解压工具,解压完成,可以将文件夹复制出来到D盘目录
3)修改配置文件
4)启动kafka
打开cmd,进入目录D:\kafka_2.12-2.8.0,执行.\bin\windows\kafka-server-start.bat .\config\server.properties
3.测试demo
1)在zookeeper和kafka启动后不要关闭,进入kafka的windows目录执行以下命令,kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic demo
2181是zookeeper端口
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消费者