kafka安装配置(转自http://blog.csdn.net/evankaka)
2018-01-31 15:48
260 查看
摘要:本文主要说明了如何在Windows安装运行Kafka
一、安装JDK
过程比较简单,这里不做说明。
二、安装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)
这是笔者最终的文件内容:
![](https://oscdn.geek-share.com/Uploads/Images/Content/201801/010d19a8ca39543969f6237aa6a8bcde)
7. 打开新的cmd,输入zkServer,运行Zookeeper。
三、安装与运行Kafka
下载
http://kafka.apache.org/downloads.html。注意要下载二进制版本的
![](https://oscdn.geek-share.com/Uploads/Images/Content/201801/401dd8fae5910dbedb02b0ba1e562e88)
下载后解压到任意一个目录,笔者的是D:\Java\Tool\kafka_2.11-0.10.0.1
1. 进入Kafka配置目录,D:\Java\Tool\kafka_2.11-0.10.0.1
2. 编辑文件“server.properties”
3. 找到并编辑log.dirs=D:\Java\Tool\kafka_2.11-0.10.0.1\kafka-log,这里的目录自己修改成自己喜欢的
4. 找到并编辑zookeeper.connect=localhost:2181。表示本地运行
5. Kafka会按照默认,在9092端口上运行,并连接zookeeper的默认端口:2181。
运行:
重要:请确保在启动Kafka服务器前,Zookeeper实例已经准备好并开始运行。
1.进入Kafka安装目录D:\Java\Tool\kafka_2.11-0.10.0.1
2.按下Shift+右键,选择“打开命令窗口”选项,打开命令行。
3.现在输入
.\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.现在输入
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic linlin
![](https://oscdn.geek-share.com/Uploads/Images/Content/201801/4713fe94f80a96c56aead425997a39db)
注意不要关了这个窗口!
(2)创建生产者
1.进入Kafka安装目录D:\Java\Tool\kafka_2.11-0.10.0.1
2.按下Shift+右键,选择“打开命令窗口”选项,打开命令行。
3.现在输入
![](https://oscdn.geek-share.com/Uploads/Images/Content/201801/16ea8b61a0ea32716e40643cc187ad4f)
注意不要关了这个窗口!
(3)创建消费者
1.进入Kafka安装目录D:\Java\Tool\kafka_2.11-0.10.0.1
2.按下Shift+右键,选择“打开命令窗口”选项,打开命令行。
3.现在输入
一、安装JDK
过程比较简单,这里不做说明。
二、安装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)
这是笔者最终的文件内容:
7. 打开新的cmd,输入zkServer,运行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.11-0.10.0.1
2. 编辑文件“server.properties”
3. 找到并编辑log.dirs=D:\Java\Tool\kafka_2.11-0.10.0.1\kafka-log,这里的目录自己修改成自己喜欢的
4. 找到并编辑zookeeper.connect=localhost:2181。表示本地运行
5. Kafka会按照默认,在9092端口上运行,并连接zookeeper的默认端口:2181。
运行:
重要:请确保在启动Kafka服务器前,Zookeeper实例已经准备好并开始运行。
1.进入Kafka安装目录D:\Java\Tool\kafka_2.11-0.10.0.1
2.按下Shift+右键,选择“打开命令窗口”选项,打开命令行。
3.现在输入
.\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.现在输入
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic linlin
注意不要关了这个窗口!
(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.现在输入
相关文章推荐
- 别人:OpenCV学习笔记(一)——安装配置、第一个程序(http://blog.csdn.net/yang_xian521/article/details/6894228)
- http://blog.csdn.net/evankaka
- Linux系统下CVS的安装、配置、仓库初始化收藏 (轉載自http://blog.csdn.net/jeanminlu/archive/2009/02/18/3906744.aspx)
- 32位Win7下安装与配置PHP环境(三) 转自.http://blog.csdn.net/yousuosi
- 配置文件解读 http://blog.csdn.net/maweifei/article/details/52965523
- linux下各种格式软件的安装(引用http://blog.csdn.net/zyz511919766/article/details/7574040)
- EFCodeFirst安装失败(包括EntityFrameWork安装) 转载自 http://blog.csdn.net/yangzhencheng_001/article/details/6684
- IBM Websphere的安装与优化 http://blog.csdn.net/lifetragedy
- 在VMWare WorkStation上安装64位操作系统(转:http://blog.csdn.net/bill_lee_sh_cn/archive/2009/03/06/3963185.aspx)
- 转-spring-boot 注解配置mybatis+druid(新手上路)-http://blog.csdn.net/sinat_36203615/article/details/53759935
- 种强行指定dll assembly读取其相应*.dll.config配置文件的方法(又名:如何创建.net 的DCOM)(转自:http://blog.csdn.net/shaily/article)
- weblogic的集群与配置 http://blog.csdn.net/lifetragedy
- 《linux硬盘安装方法 》——引自 http://blog.csdn.net/rusi_lsk/
- emacs----陈斌----配置步骤http://blog.csdn.net/lldustc_blog/article/details/8566809
- ICTCLAS分词系统Java调用接口在Eclipse中的安装 http://blog.csdn.net/CloneIQ/archive/2006/07/20/945909.aspx
- 简单驱动开发配置(转自http://blog.csdn.net/yinxu/archive/2007/11/12/1880561.aspx)经典
- Pet store的安装---http://blog.csdn.net/kevinluck/archive/2007/04/14/1564715.aspx
- 10Android Wifi 移植配置 http://blog.csdn.net/wh_19910525/article/details/7397570
- [转] VS2005制作Web安装程序 [http://blog.csdn.net/rainbowsoftware/archive/2007/08/01/1721296.aspx]
- 如何在cmd下切换不同版本的Python 原文:windows 安装python2 与python3 共存 地址:http://blog.csdn.net/liulucaro/article/de