赞
踩
kafka要和ZooKeeper、jdk配合使用,所以要先安装jdk和zookeeper
1.zookeeper下载地址
https://zookeeper.apache.org/releases.html#download
2.同版本下有两个下载包,下载红色框标注的包
3.因为是tar.gz包,所以解压两次如图: 把整个目录拷贝到自己工作的盘符下
4.打开zookeeper目录,新建两个文件夹 log 和 data
5.打开conf文件夹 将“zoo_sample.cfg”重命名为“zoo.cfg”
打开“zoo.cfg”找到并且编辑
dataDir=E:\zookeeper\apache-zookeeper-3.5.9-bin\data
在添加一个日志路径
dataLogDir=E:\zookeeper\apache-zookeeper-3.5.9-bin\log
(注意我的在E盘zookeeper下,路径改成自己的目录)
6.添加zookeeper到环境变量中
7.打开cmd,输入 zkServer 运行Zookeeper
此窗口不要关闭,接下来的kafka需要用到
1.kafka下载地址
https://kafka.apache.org/downloads
2.下载解压完如图(放到自己工作的盘符目录下,我的在E:kafka下)
3.进入config目录找到文件server.properties打开,
找到并且修改 log.dirs=E:\kafka\kafka_2.13-2.8.0\logs
4 Zookeeper端口默认2181),kafka文件里面zookeeper的连接设置默认端口也是2181不用修改
Kafka会按照默认,在9092端口上运行,并连接zookeeper的默认端口:2181
到此kafka安装完毕
5 进入到kafka安装目录 E:\kafka\kafka_2.13-2.8.0 ,然后Shift+鼠标右键,打开Powershell窗口
6 在窗口输入下面的值启动kafka(zookeeper服务必须启动中,安装zookeeper步骤中有启动步骤)
.\bin\windows\kafka-server-start.bat .\config\server.properties
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topictest
目前为止应该有3个命令行窗口
2.创建生产者,进入kafka目录 E:\kafka\kafka_2.13-2.8.0,然后 Shift+鼠标右键,打开Powershell窗口 输入如下值 并回车:
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic topictest
3.创建消费者,进入kafka目录 E:\kafka\kafka_2.13-2.8.0,然后 Shift+鼠标右键,打开Powershell窗口 输入如下值 并回车:
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic topictest --from-beginning
4.输入测试英文查看通信,
在生产者(producer.bat)窗口 输入英文值测试,输入完值回车一下,消费者窗口同步出现值
消费者窗口会出现同样的值,测试OK!
https://blog.csdn.net/zhanghengchao123/article/details/122150066
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。