2.1 kafka - windows安装
2021/9/15 7:06:40
本文主要是介绍2.1 kafka - windows安装,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
参考 https://blog.csdn.net/tiantangdizhibuxiang/article/details/80556064
kafka使用依赖于zookeeper,两个都要下载 1.下载ZooKeeper https://zookeeper.apache.org/releases.html 选第一个,一定要是名字带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 ------------------------------------------------------------------ 2.kafka下载 http://kafka.apache.org/downloads.html 注意要下载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安装的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-12-21MQ-2烟雾传感器详解
- 2024-12-09Kafka消息丢失资料:新手入门指南
- 2024-12-07Kafka消息队列入门:轻松掌握Kafka消息队列
- 2024-12-07Kafka消息队列入门:轻松掌握消息队列基础知识
- 2024-12-07Kafka重复消费入门:轻松掌握Kafka消费的注意事项与实践
- 2024-12-07Kafka重复消费入门教程
- 2024-12-07RabbitMQ入门详解:新手必看的简单教程
- 2024-12-07RabbitMQ入门:新手必读教程
- 2024-12-06Kafka解耦学习入门教程
- 2024-12-06Kafka入门教程:快速上手指南