当前位置: 首页 > news >正文

windows下启动和运行分布式消息中间件消息队列 kafka

本文转载至:https://www.cnblogs.com/flower1990/p/7466882.html

一、安装JAVA JDK

1、下载安装包

http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html

注意:根据32/64位操作系统下载对应的安装包

2、添加系统变量:JAVA_HOME=C:\Program Files (x86)\Java\jdk1.8.0_144

二、安装ZooKeeper

1、 下载安装包

http://zookeeper.apache.org/releases.html#download

2、 解压并进入ZooKeeper目录,笔者:D:\Kafka\zookeeper-3.4.9\conf

3、 将“zoo_sample.cfg”重命名为“zoo.cfg”

4、 打开“zoo.cfg”找到并编辑dataDir=D:\\Kafka\zookeeper-3.4.9\\tmp

5、 添加系统变量:ZOOKEEPER_HOME=D:\Kafka\zookeeper-3.4.9

6、 编辑path系统变量,添加路径:%ZOOKEEPER_HOME%\bin

7、 在zoo.cfg文件中修改默认的Zookeeper端口(默认端口2181)

8、 打开新的cmd,输入“zkServer“,运行Zookeeper

9、 命令行提示如下:说明本地Zookeeper启动成功

image

注意:不要关了这个窗口

三、安装Kafka

1、 下载安装包

http://kafka.apache.org/downloads

注意要下载二进制版本

clip_image003

2、 解压并进入Kafka目录,笔者:D:\Kafka\kafka_2.12-0.11.0.0

3、 进入config目录找到文件server.properties并打开

4、 找到并编辑log.dirs=D:\Kafka\kafka_2.12-0.11.0.0\kafka-logs

5、 找到并编辑zookeeper.connect=localhost:2181

6、 Kafka会按照默认,在9092端口上运行,并连接zookeeper的默认端口:2181

7、 进入Kafka安装目录D:\Kafka\kafka_2.12-0.11.0.0,按下Shift+右键,选择“打开命令窗口”选项,打开命令行,输入:

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

image

注意:注意:不要关了这个窗口,启用Kafka前请确保ZooKeeper实例已经准备好并开始运行

四、测试

1、 创建主题,进入Kafka安装目录D:\Kafka\kafka_2.12-0.11.0.0,按下Shift+右键,选择“打开命令窗口”选项,打开命令行,输入:

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

clip_image005

注意:不要关了这个窗口

查看主题输入:

.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

clip_image007

2、 创建生产者,进入Kafka安装目录D:\Kafka\kafka_2.12-0.11.0.0,按下Shift+右键,选择“打开命令窗口”选项,打开命令行,输入:

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

image

注意:不要关了这个窗口

3、 创建消费者,进入Kafka安装目录D:\Kafka\kafka_2.12-0.11.0.0,按下Shift+右键,选择“打开命令窗口”选项,打开命令行,输入:

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

image

4、 大功告成

参考网址:

http://kafka.apache.org/

https://github.com/confluentinc/confluent-kafka-dotnet

http://www.cnblogs.com/cyfonly/p/5954614.html

http://blog.csdn.net/evankaka/article/details/52421314

转载于:https://www.cnblogs.com/fly-boy/p/10069686.html

相关文章:

  • 关系与外键约束
  • TP自动生成模块目录
  • maven私服搭建
  • canvas 使用图片跨域问题
  • MySQL的安装与配置
  • redhat7.5在H3C机器上黑屏无显
  • 超级详细使用Webpack4.X 搭建H5开发环境
  • 真数组与伪数组的区别
  • 搜狗地图下载|搜狗地图app下载
  • 腾讯朱华:数据中心下一个风向的探索
  • 汇编语言实验9
  • CentOS 7下mysqld服务启动失败终极解决方案
  • 【Python】【翻转字符串】
  • 记一次华硕X205t思聪本 重装系统,安装win8和linux双系统
  • Vue 单页应用(spa)前端路由实现原理
  • Android单元测试 - 几个重要问题
  • ERLANG 网工修炼笔记 ---- UDP
  • JS+CSS实现数字滚动
  • Mocha测试初探
  • Mysql优化
  • npx命令介绍
  • python3 使用 asyncio 代替线程
  • python学习笔记-类对象的信息
  • Tornado学习笔记(1)
  • 编写高质量JavaScript代码之并发
  • 基于 Ueditor 的现代化编辑器 Neditor 1.5.4 发布
  • 如何编写一个可升级的智能合约
  • 微信开放平台全网发布【失败】的几点排查方法
  • 我有几个粽子,和一个故事
  • 我这样减少了26.5M Java内存!
  • 一个普通的 5 年iOS开发者的自我总结,以及5年开发经历和感想!
  • 一个项目push到多个远程Git仓库
  • 宾利慕尚创始人典藏版国内首秀,2025年前实现全系车型电动化 | 2019上海车展 ...
  • ​ssh-keyscan命令--Linux命令应用大词典729个命令解读
  • ​插件化DPI在商用WIFI中的价值
  • ​总结MySQL 的一些知识点:MySQL 选择数据库​
  • ![CDATA[ ]] 是什么东东
  • # include “ “ 和 # include < >两者的区别
  • #QT(智能家居界面-界面切换)
  • $.ajax()
  • (10)STL算法之搜索(二) 二分查找
  • (9)YOLO-Pose:使用对象关键点相似性损失增强多人姿态估计的增强版YOLO
  • (C)一些题4
  • (附源码)ssm考试题库管理系统 毕业设计 069043
  • (附源码)计算机毕业设计大学生兼职系统
  • (区间dp) (经典例题) 石子合并
  • (删)Java线程同步实现一:synchronzied和wait()/notify()
  • (五) 一起学 Unix 环境高级编程 (APUE) 之 进程环境
  • (循环依赖问题)学习spring的第九天
  • (一)为什么要选择C++
  • (转)Android中使用ormlite实现持久化(一)--HelloOrmLite
  • (转)VC++中ondraw在什么时候调用的
  • .htaccess配置重写url引擎
  • .net 7 上传文件踩坑
  • .net core使用ef 6