首页 > Windows开发 > 详细

2.1 kafka - windows安装

时间:2021-09-16 12:14:50      阅读:29      评论:0      收藏:0      [点我收藏+]

参考 https://blog.csdn.net/tiantangdizhibuxiang/article/details/80556064

 
kafka使用依赖于zookeeper,两个都要下载
技术分享图片
 
技术分享图片
技术分享图片
选第一个,一定要是名字带bin的那个 ,不能是源码包 (带source)
否则zkserver 启动时报以下错
技术分享图片
 
 
环境变量 jdk三个要先配好
ZOOKEEPER_HOME: D:\apache-zookeeper-3.6.2-bin
 
path: ;%ZOOKEEPER_HOME%\bin;
 
conf文件中zoo_sample.cfg重命名为zoo.cfg ,zoo_sample.cfg代表样本配置,启动zookeeper是默认找的是zoo.cfg,所以名字要改
打开后修改 dataDir=D:\apache-zookeeper-3.6.2-bin\data
D:\apache-zookeeper-3.6.2-bin是我的zookeeper目录 貌似这么写才能打印到当前目录dataDir=data
 
cmd执行
zkserver 启动 ZooKeeper
 
------------------------------------------------------------------
技术分享图片
 
注意要下载Binary的那两个之一,不能是源码包(带source)
技术分享图片
 
否则 .\bin\windows\kafka-server-start.bat .\config\server.properties 报以下错 注意两个文件中间有空格
技术分享图片
 
conf中server.properties打开修改log.dirs=D:\kafka_2.12-2.7.0\kafka-logs
D:\kafka_2.12-2.7.0是我的kafka目录 貌似这么写才能打印到当前目录log.dirs=kafka-logs
 
 
配置总的来说就两步
zookeeper:
环境变量 除了系统环境变量,用户环境变量也要设置。。。
ZOOKEEPER_HOME D:\mycarrer\centre\apache-zookeeper-3.6.2-bin
path ;%ZOOKEEPER_HOME%\bin;
日志目录
zoo_sample.cfg
dataDir = D:\mycarrer\centre\apache-zookeeper-3.6.2-bin\data
 
kafka
日志目录
server.properties
log.dirs=D:\mycarrer\centre\kafka_2.12-2.7.0\kafka-logs
 
 
*总体执行步骤 5步,打开5个窗口,在生产者窗口写消息后再消费者窗口可以实时接收
 
注:这5步是window测试, 在java应用中,只需要前2步,其他在代码中指定即可!
zookeeper默认对口是2181,
kafka-broker,也就是kafka服务- 默认端口是9092,producer往进写,consumer往出读!
 
1.启动zookeeper
cmd执行zkserver
 
2.启动kafka 进入D:\kafka_2.12-2.7.0 //cmd先输入D: 进入D盘 ,然后输入cd D:\kafka_2.12-2.7.0才能进入
.\bin\windows\kafka-server-start.bat .\config\server.properties
 
3.创建主题 进入D:\kafka_2.12-2.7.0\bin\windows
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
 
4.创建生产者 进入D:\kafka_2.12-2.7.0\bin\windows
kafka-console-producer.bat --broker-list localhost:9092 --topic test
 
5.创建消费者 进入D:\kafka_2.12-2.7.0\bin\windows
kafka-console-consumer.bat --zookeeper localhost:2181 --topic test 旧版
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test
 
使用旧版消费者命令会报以下错
技术分享图片
 
使用git操作时命令需要变动,否则报错 例如zkserver要变成zkServer.cmd
技术分享图片
 
另外,在linux环境需要注意,
1.使用.sh非.bat或.cmd
2.命令启动.\估计要用./
 
 
 

2.1 kafka - windows安装

原文:https://www.cnblogs.com/zl-programmer/p/15269072.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!