安装zookeeper

1.下载zookeeper安装包并解压文件(本文解压到 D:\zookeeper-3.4.10)
2.打开D:\zookeeper-3.4.10\conf,把zoo_sample.cfg重命名成zoo.cfg
3.从文本编辑器里打开zoo.cfg ,修改dataDir和dataLogDir保存路径
windows平台kafka环境的搭建
4.修改环境变量
ZOOKEEPER_HOME: D:\zookeeper-3.4.10
windows平台kafka环境的搭建
path:在现有的值后面添加 ;%ZOOKEEPER_HOME%\bin;
windows平台kafka环境的搭建
5.打开cmd然后在D:\zookeeper-3.4.10\bin目录执行zkServer命令。如果打印以下信息则表示zookeeper已经安装成功并运行在2181端口。
windows平台kafka环境的搭建
windows平台kafka环境的搭建

安装kafka

1.下载kafka安装包并解压文件(本文解压到D:\kafka_2.12-2.0.0)
2.打开D:\kafka_2.12-2.0.0\config\server.properties ,把 log.dirs的值改成log.dirs=D:\kafka_2.12-2.0.0\kafka-logs
windows平台kafka环境的搭建
3.修改环境变量
KAFKA_HOME: D:\kafka_2.12-2.0.0
windows平台kafka环境的搭建
path:在现有的值后面添加 ;%KAFKA_HOME%\bin\windows;
windows平台kafka环境的搭建
4.在D:\kafka_2.12-2.0.0文件夹下执行.bat命令脚本

.\bin\windows\kafka-server-start.bat .\config\server.properties

显示的信息如下,则表示正常运行
windows平台kafka环境的搭建

运行kafka

1.创建一个名为steven的topic,另启一个cmd并在D:\kafka_2.12-2.0.0\bin\windows文件夹中运行以下命令

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic steven

windows平台kafka环境的搭建
2.创建一个生产者,在D:\kafka_2.12-2.0.0\bin\windows文件夹中运行以下命令

kafka-console-producer.bat --broker-list localhost:9092 --topic steven

windows平台kafka环境的搭建
3.创建一个消费者,另启一个cmd并在D:\kafka_2.12-2.0.0\bin\windows文件夹中运行以下命令

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic steven 

windows平台kafka环境的搭建
4.测试
在生产者窗口输入信息,如下所示,可在消费者窗口看到相应的消息
windows平台kafka环境的搭建
windows平台kafka环境的搭建

相关文章: