windows下的zookeeper和kafka安装及配置

• Zookeeper****下载配置

官网下载zookeeper压缩包：

https://archive.apache.org/dist/zookeeper/zookeeper-3.6.4/apache-zookeeper-3.6.4-bin.tar.gz

环境变量配置如下：

zookeeper根目录下新建data和logs文件

打开根目录下conf文件，复制zoo_sample.cfg文件，命名为zoo.cfg

记事本打开，修改

dataDir=E:\\apache-zookeeper-3.6.4-bin\\data

添加日志路径：

dataDirLog=E:\\apache-zookeeper-3.6.4-bin\\logs

bin目录下找到zkEnv.sh文件，记事本打开，找到ZOOCFG的文件名改成zoo.cfg（就是我们之前复制改名的那个文件）

在控制台cmd中输入zkServer，启动Zookeeper：

管理员模式打开命令控制台，客户端连接zookeeper。

输入

zkCli

输入ls /

ls /

• Kafka****下载配置

Apache Kafka

点击下载scala2.12对应的压缩包:

在kafka下载好的根目录下，创建新文件夹：log

编辑文件Kafka配置文件，\config\server.properties

找到并编辑

log.dirs=E:\\kafka_2.12-3.4.0\\log

在同一目录下找到最低端的zookeeper.conf

打开修改“dataDir=”部分为zookeeper的根目录：

dataDir=E:\\apache-zookeeper-3.6.4-bin

• 利用Kafka生产消息并消费

准备工作

Zookeeper服务启动：

zkServer

Kafka服务启动，进入kafka根目录：

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

在kafka中创建主题topic

创建主题，命名为"mytopic"，replicationfactor=1（只有一个卡夫卡服务器在运行）。

在kafka根目录"E:\kafka_2.12-3.4.0"中打开命令行，输入以下命令：

.\bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --topic mytopic --partitions 1 --replication-factor 1

查看已拥有的topic

bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092

发送与监听

创建消费者消息监控控制台：

bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic Test_demo --from-beginning

启动生产者消息发送平台：

 bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic Test_demo

生产者消息发送输入：

消费者监听结果接收结果：