一安装JDK

二zookeeper安装    Apache ZooKeeper 

 

conf下修改cfg文件名 为zoo.cfg

 打开该文件编辑

配置环境变量  右击电脑--属性--高级系统设置--选择环境变量

新建系统变量
变量名：ZOOKEEPER_HOME

变量值为zookeeper的路径

 然后编辑环境变量Path 新增%ZOOKEEPER_HOME%\bin

 三 kafka安装  Apache Kafka

解压

编辑config文件夹中的server.properties 

 四 测试消息

一启动zookeeper

bin文件夹下 双击zkServer.cmd （不要关闭

 ​​​​​​​

 

 二启动kafka

该目录下打开命令窗口 cmd

输入.\bin\windows\kafka-server-start.bat .\config\server.properties（不要关闭

再打开一个命令窗口用于 输入以下命令

创建主题

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1

创建成功 不要关闭 

查看主题

 .\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181 --topic test1

再打开一个命令窗口用做生产者输入以下命令

.\bin\windows\kafka-console-producer.bat --bootstrap-server localhost:9092 --topic test1（不要关闭

再打开一个命令窗口用于消费者输入以下命令

.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --from-beginning --topic test1（不要关闭

 然后在生产者窗口输入消息  消费者窗口会接收到消息如上图，至此完成测试消息