










版本:(参考:https://cloud.tencent.com/developer/article/2153563) jdk java version "1.8.0_31" (环境变量配置自行配置忽略) zookeeper : 3.9.3 kafka : kafka_2.12-3.9.1 zookeeper 下载地址:https://dlcdn.apache.org/zookeeper/zookeeper-3.9.3/ (要下载二进制的文件夹) kafka 下载地址:https://kafka.apache.org/downloads
1.安装zookeeper 1.1 解压apache-zookeeper-3.9.3-bin.tar.gz 1.2 进入zookeeper目录,如:D:\\Kafka\\apache-zookeeper-3.9.3-bin\\apache-zookeeper-3.9.3-bin\\conf 1.3 将“zoo_sample.cfg”重命名为“zoo.cfg” 1.4 打开“zoo.cfg”找到并编辑dataDir=D:\\Kafka\\zookeeper-3.4.9\\tmp(必须以\\分割) 1.5 增加配置参数 audit.enable=true 1.6 添加系统变量:ZOOKEEPER_HOME=D:\Kafka\zookeeper-3.4.9 1.7 编辑path系统变量,添加路径:%ZOOKEEPER_HOME%\bin 1.8 在zoo.cfg文件中修改默认的Zookeeper端口(默认端口2181) 1.9 打开新的cmd,输入“zkServer“,运行Zookeeper

2.安装kafka(这里一定要注意,目录不要太深,不然无法启动)(参考:https://blog.csdn.net/qq_43513957/article/details/135367201) 2.1 解压kafka_2.12-3.9.1.tgz 2.2 进入kafka目录,如:D:\\kafka\\kafka_2.12-3.9.1\\config 2.3 找到文件server.properties并打开 2.4 找到并编辑log.dirsD:\\Kafka\\kafka_2.12-3.9.1\\kafka-logs 2.5 找到并编辑zookeeper.connect=localhost:2181
2.6 Kafka会按照默认,在9092端口上运行,并连接zookeeper的默认端口:2181 2.7 启动命令:.\bin\windows\kafka-server-start.bat .\config\server.properties

3. 测试,创建topic(参考:https://developer.aliyun.com/article/1372261) .\bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

4.测试 创建生产者 .\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

不关闭生产者的情况下,再打开一个窗口,启动一个消费者进行监听数据... D:\kafka_2.12-3.9.1> .\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

此内容由惯性聚合(RSS阅读器)自动聚合整理,仅供阅读参考。 原文来自 — 版权归原作者所有。