近期在搞kafka,在Windows环境搭建的过程中遇到一些问题,把具体的流程几下来防止后面忘了。 
准备工作: 
1.安装jdk环境 
http://www.oracle.com/technetwork/java/javase/downloads/index.html 
2.下载kafka的程序安装包: 
http://kafka.apache.org/downloads 
解压文件提取出里面的文件 
在cmd命令行打开至根目录下,内容如下: 
 
(1).bin目录下存放的是程序运行时使用的脚本文件,window平台是一个独立的文件夹里面存放着 .bat 文件,bin的目录下存放的是 Linux 平台使用的 .sh 的shell脚本,在window平台上用不到,嫌麻烦可以删了。 
(2).config目录下存放的是一些程序运行的配置文件,在后期自定义使用kafka的时候需要修改里面的文件内容。 
(3).libs目录是打包好的jar包,这个版本自带了zookeeper的jar包,所以在安装的过程中不需要再在本地安装zookeeper了。

启动zookeeper: 
  在正常启动zoopkeeper之前需要修改zookeeper.properties的文件内容,将其data的输出目录指定一下,可自行创建一个文件夹如下: 
 
然后启动:

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

正常启动后他的状态是这样的: 
 
3. 启动kfaka服务: 
在启动前,任然需要修改server.properties中log.dir的配置目录, 
 
修改后,启动服务: 
 
4. 创建一个主题:

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

可以使用如下命令查看创建的主题列表:

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

 
5. 启动生产者:

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

此时可以从控制台输入信息,待消费者启动后可接收到生产者发布的消息。 
 
6. 启动消费者:

bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic kjTest --from-beginning

此时便能看到发布出去的消息了 
 
7. 在后期还可以启动多个集群服务,同时进行操作,修改server.properties中的内容:便可启动,与上相似。

config/server-1.properties:broker.id=<new id>listeners=PLAINTEXT://:<new port>log.dir=<you log dir>   

操作步骤:

1).分别启动需要的kafka服务

2). 创建主题,设置分区数目 

可以使用下面的命令查看是否创建成功,和具体的分区 

3). 分别启动生产者消费者 

4). 可以查看下当前工作状态 

查看得当前服务使用的是broker编号为2的服务,但我们将其down掉后 

再次执行消息发送任务: 

 
消息仍能发送成功,命令行中会提示一个服务已关闭。 
就查看当前状态: 

此时的leader换成了broker 0

转自:https://blog.csdn.net/qq_32485573/article/details/54562237?locationNum=5&fps=1

Windows平台下kafka环境的搭建相关推荐

  1. Windows平台下NS2网络仿真环境的搭建

    NS2(Network Simulator 2) 是一种针对网络技术的源代码公开的.免费的软件模拟平台,研究人员使用它可以很容易的进行网络技术的开发,而且发展到今天,它所包含的模块几乎涉及到了网络技术 ...

  2. Windows平台下Glade+GTK开发环境的搭建

    [@.1 MVVM设计模式与Glade] 做上层软件开发的程序员可能对于MVVM模式比较熟悉,这是一种经典的软件设计模式,很好的将用户界面与后台处理之间分层开,通过属性.事件绑定这种统一的" ...

  3. Windows平台下Git服务器搭建

    初识Git Git是什么? Git是目前世界上最先进的分布式版本控制系统. SVN与Git的最主要的区别? SVN是集中式版本控制系统,版本库是集中放在中央服务器的,而干活的时候,用的都是自己的电脑, ...

  4. windows平台下vlc编译

    转自:http://jeremiah.blog.51cto.com/539865/114190     Jeremiah刚刚工作几个月,参与的第一个项目是与视频监控有关,分配给我的任务就是用开源的vl ...

  5. windows平台下vlc编译之十三:vlc1.1.0编译

    请移步https://higoge.github.io/,所有下载资料在那个博客都能找到.谢谢. --------------------------------------------------- ...

  6. windows平台下vlc编译之六:vlc-0.9.8a的编译

    请移步https://higoge.github.io/,所有下载资料在那个博客都能找到.谢谢. --------------------------------------------------- ...

  7. Windows平台下Makefile学习笔记

    来源:http://blog.csdn.net/clever101 决心学习Makefile,一方面是为了解决编译开源代码时需要跨编译平台的问题(发现一些开源代码已经在使用VS2010开发,但我还没安 ...

  8. windows平台下,有什么好的分屏软件推荐?3款让窗口布局更合理的App

    windows平台下,有什么好的分屏软件推荐?Windows 10 系统为例,系统自带功能支持二分屏/三分屏/四分屏的分屏方式.比如用户通过鼠标将应用窗口拖到屏幕边缘,窗口会自动以占据 1/2 屏幕大 ...

  9. windows平台下VLC2.0.5编译

    windows平台下VLC2.0.5编译说明 时隔一年多,又要搞流媒体了,不过这次是要做流媒体服务器. 暂时决定使用vlc+ffmpeg+live555,虽然听有些前辈说这个组合的性能较差,只能作为学 ...

最新文章

  1. SDOI2015寻宝游戏 dfs序+set
  2. 最大矩形面积_JAVA
  3. python爬取音乐并保存_python3 实现爬取TOP500的音乐信息并存储到mongoDB数据库中
  4. 什么是死锁(deadlock)?
  5. 对openflow 1.0协议的扩展
  6. Antd如何用Menu组件渲染二级或三级目录
  7. A64 base instruction -- orr
  8. 相同的js文件在IE浏览器可以响应,但是在Chrome浏览器上没有响应
  9. spring boot火车票售卖系统毕业设计代码211004
  10. Canvas 画九宫格图片
  11. Apriori算法及例题
  12. 现在有一个未分库分表的系统,未来要分库分表,如何设计才可以让系统从未分库分表动态切换到分库分表上?
  13. vue-element-admin改造顶部一级导航,侧边二级导航+权限路由
  14. 液晶拼接处理器_液晶拼接大屏运用设施
  15. Win11和Win10怎么禁用驱动程序强制签名? 关闭Windows系统驱动强制签名的技巧?
  16. 翻译:(MPN-Cov)Is Second-order Information Helpful for Large-scale Visual Recognition?
  17. MySQL——子查询用法
  18. 投递的简历没有收到答复,有哪些细节需要注意?
  19. 全球及中国盾构机市场分析与发展格局展望报告2022版
  20. iPhone查找序列号生成函数

热门文章

  1. php xml表格形式输出,PHP XML如何输出nice格式
  2. JAVA和javascrito_JAVA 和JavaScript的split方法异同
  3. sys.stdin.read和raw_input函数
  4. Bean的scope属性
  5. 101. 对称二叉树 golang
  6. 86. 分隔链表 golang
  7. 518. 零钱兑换 II golang动态规划
  8. 僵尸进程的产生,危害和解决方案
  9. 详解malloc,calloc,realloc原理及其模拟实现
  10. QT子线程与主线程的信号槽通信