设为首页 加入收藏

TOP

kafka在windows上安装运行
2019-05-02 02:31:10 】 浏览:42
Tags:kafka windows 安装 运行

摘要:本文主要说明了如何在Windows安装运行Kafka

一、安装JDK

过程比较简单,这里不做说明。

最后打开cmd输入如下内容,表示安装成功


二、安装zooeleeper

下载安装包:http://zookeeper.apache.org/releases.html#download

下载后解压到一个目录:

1.进入Zookeeper设置目录,笔者D:\Java\Tool\zookeeper-3.4.6\conf
2. 将“zoo_sample.cfg”重命名为“zoo.cfg”
3. 在任意文本编辑器(如notepad)中打开zoo.cfg
4. 找到并编辑dataDir=D:\\Java\\Tool\\zookeeper-3.4.6\\tmp
5. 与Java中的做法类似,我们在系统环境变量中添加:
  a. 在系统变量中添加ZOOKEEPER_HOME = D:\Java\Tool\zookeeper-3.4.6
  b. 编辑path系统变量,添加为路径%ZOOKEEPER_HOME%\bin;
6. 在zoo.cfg文件中修改默认的Zookeeper端口(默认端口2181)

这是笔者最终的文件内容:

  1. #Thenumberofmillisecondsofeachtick
  2. tickTime=2000
  3. #Thenumberofticksthattheinitial
  4. #synchronizationphasecantake
  5. initLimit=10
  6. #Thenumberofticksthatcanpassbetween
  7. #sendingarequestandgettinganacknowledgement
  8. syncLimit=5
  9. #thedirectorywherethesnapshotisstored.
  10. #donotuse/tmpforstorage,/tmphereisjust
  11. #examplesakes.
  12. dataDir=D:\\Java\\Tool\\zookeeper-3.4.6\\tmp
  13. #theportatwhichtheclientswillconnect
  14. clientPort=2181
  15. #themaximumnumberofclientconnections.
  16. #increasethisifyouneedtohandlemoreclients
  17. #maxClientCnxns=60
  18. #
  19. #Besuretoreadthemaintenancesectionofthe
  20. #administratorguidebeforeturningonautopurge.
  21. #
  22. #http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
  23. #
  24. #ThenumberofsnapshotstoretainindataDir
  25. #autopurge.snapRetainCount=3
  26. #Purgetaskintervalinhours
  27. #Setto"0"todisableautopurgefeature
  28. #autopurge.purgeInterval=1

7. 打开新的cmd,输入zkServer,运行Zookeeper。
8. 命令行提示如下:说明本地Zookeeper启动成功(注意保持zookeeper运行中,即:不要关掉这个终端,)


三、安装与运行Kafka

下载

http://kafka.apache.org/downloads.html。注意要下载二进制版本的


下载后解压到任意一个目录,笔者的是D:\Java\Tool\kafka_2.11-0.10.0.1

1. 进入Kafka配置目录,D:\Java\Tool\kafka_2.12-1.1.0
2. 编辑文件“server.properties”
3. 找到并编辑log.dirs=D:\Java\Tool\kafka_2.12-1.1.0\kafka-log,这里的目录自己修改成自己喜欢的
4. 找到并编辑zookeeper.connect=localhost:2181。表示本地运行
5. Kafka会按照默认,在9092端口上运行,并连接zookeeper的默认端口:2181。

运行:

重要:请确保在启动Kafka服务器前,Zookeeper实例已经准备好并开始运行

1.进入Kafka安装目录D:\Java\Tool\kafka_2.12-1.1.0
2.按下Shift+右键,选择“打开命令窗口”选项,打开命令行。(win7、win8)win10详见:https://blog.csdn.net/xfyangle/article/details/75030062
3.现在输入

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

并回车。


四、测试

上面的Zookeeper和kafka一直打开

(1)、创建主题

1.进入Kafka安装目录D:\Java\Tool\kafka_2.11-0.10.0.1
2.按下Shift+右键,选择“打开命令窗口”选项,打开命令行。
3.现在输入

  1. .\bin\windows\kafka-topics.bat--create--zookeeperlocalhost:2181--replication-factor1--partitions1--topiclinlin


注意不要关了这个窗口!

(2)创建生产者

1.进入Kafka安装目录D:\Java\Tool\kafka_2.11-0.10.0.1
2.按下Shift+右键,选择“打开命令窗口”选项,打开命令行。
3.现在输入


注意不要关了这个窗口!

(3)创建消费者

1.进入Kafka安装目录D:\Java\Tool\kafka_2.11-0.10.0.1
2.按下Shift+右键,选择“打开命令窗口”选项,打开命令行。
3.现在输入


注意不要关了这个窗口!

然后在第2个窗口中输入内容,最后记得回车


大功告成!

使用Java编写的kafka使用实例如下:

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


转载自:https://blog.csdn.net/evankaka/article/details/52421314

】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇简单说明什么是kafka 下一篇认识KafKa-深入解析Leader和Follo..

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目