Windows单机配置Kafka环境
2017-10-11 10:26
337 查看
首先确保机器已经安装好Zookeeper,Zookeeper安装参考
Windows单机配置Zookeeper环境
然后确保Zookeeper是正常启动状态
下载Kafka
http://kafka.apache.org/downloads.html
![](http://upload-images.jianshu.io/upload_images/2518871-27baab9a85d27925.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
下载二进制包
下载后解压缩,我这里解压缩到了 D:\WorkSoftware\kafka_2.11_0.10.1.0 目录
![](http://upload-images.jianshu.io/upload_images/2518871-a88c62e42007939f.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
解压缩
首先建立一个空文件夹 logs
![](http://upload-images.jianshu.io/upload_images/2518871-ddb15a71e0a088f4.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
建立logs文件夹
进入config目录,编辑 server.properties 文件
![](http://upload-images.jianshu.io/upload_images/2518871-3d76a86898e42438.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
编辑server.properties
修改 log.dirs 属性部分的地址
![](http://upload-images.jianshu.io/upload_images/2518871-7bd678d582d7c286.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
修改log.dirs属性
然后在 D:\WorkSoftware\kafka_2.11_0.10.1.0 目录,按住shift+鼠标右键
![](http://upload-images.jianshu.io/upload_images/2518871-eb80f70b60afd03a.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
在此处打开命令窗口
然后输入下面命令
![](http://upload-images.jianshu.io/upload_images/2518871-c2d91434e19ad1c9.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
回车,执行命令
![](http://upload-images.jianshu.io/upload_images/2518871-5a9551803957c53d.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
出现错误
如果出现错误,我这里分析是CLASSPATH没有配置正确,那么,先设置CLASSPATH,然后再执行
![](http://upload-images.jianshu.io/upload_images/2518871-5e13df3c085481f6.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
设置CLASSPATH
![](http://upload-images.jianshu.io/upload_images/2518871-f8d6f68d65c53544.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
成功
测试一下,首先进入 D:\WorkSoftware\kafka_2.11-0.10.1.0\bin\windows 目录,然后在当前目录打开命令窗口
![](http://upload-images.jianshu.io/upload_images/2518871-4c3f5fa758d524a3.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
输入下面命令,创建一个topic
如果还遇到无法加载类等错误,还是先设置CLASSPATH
![](http://upload-images.jianshu.io/upload_images/2518871-fbfbf4c586577c80.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
遇到无法加载主类,需要设置CLASSPATH
![](http://upload-images.jianshu.io/upload_images/2518871-e4471d15c7cf6ffc.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
topic创建成功
打开一个Producer
![](http://upload-images.jianshu.io/upload_images/2518871-4c86c781ef1bf19b.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
执行命令,打开生产者
这三个窗口不关闭的情况下(zookeeper/kafka/producer),再次开启一个命令窗口(还是在kafka目录右键打开),输入下面命令,开启Consumer
![](http://upload-images.jianshu.io/upload_images/2518871-e53e11f4e6745fbc.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
这样,这里就有4个命令窗口
![](http://upload-images.jianshu.io/upload_images/2518871-480b67a8ff96acc2.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
分别是
Zookeeper
Kafka
Producer
Consumer
下面,我们在3号窗口(Producer)输入一些字符,就会看到4号窗口马上就收到消息
![](http://upload-images.jianshu.io/upload_images/2518871-cc9942c69733fee0.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
至此,Kafka的Windows单机环境搭建完毕
作者:sphsyv
链接:http://www.jianshu.com/p/64d25dcf8300
來源:简书
著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。
Windows单机配置Zookeeper环境
然后确保Zookeeper是正常启动状态
下载Kafka
http://kafka.apache.org/downloads.html
![](http://upload-images.jianshu.io/upload_images/2518871-27baab9a85d27925.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
下载二进制包
下载后解压缩,我这里解压缩到了 D:\WorkSoftware\kafka_2.11_0.10.1.0 目录
![](http://upload-images.jianshu.io/upload_images/2518871-a88c62e42007939f.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
解压缩
首先建立一个空文件夹 logs
![](http://upload-images.jianshu.io/upload_images/2518871-ddb15a71e0a088f4.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
建立logs文件夹
进入config目录,编辑 server.properties 文件
![](http://upload-images.jianshu.io/upload_images/2518871-3d76a86898e42438.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
编辑server.properties
修改 log.dirs 属性部分的地址
![](http://upload-images.jianshu.io/upload_images/2518871-7bd678d582d7c286.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
修改log.dirs属性
然后在 D:\WorkSoftware\kafka_2.11_0.10.1.0 目录,按住shift+鼠标右键
![](http://upload-images.jianshu.io/upload_images/2518871-eb80f70b60afd03a.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
在此处打开命令窗口
然后输入下面命令
.\bin\windows\kafka-server-start.bat .\config\server.properties
![](http://upload-images.jianshu.io/upload_images/2518871-c2d91434e19ad1c9.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
回车,执行命令
![](http://upload-images.jianshu.io/upload_images/2518871-5a9551803957c53d.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
出现错误
如果出现错误,我这里分析是CLASSPATH没有配置正确,那么,先设置CLASSPATH,然后再执行
SET CLASSPATH=.;
![](http://upload-images.jianshu.io/upload_images/2518871-5e13df3c085481f6.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
设置CLASSPATH
![](http://upload-images.jianshu.io/upload_images/2518871-f8d6f68d65c53544.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
成功
测试一下,首先进入 D:\WorkSoftware\kafka_2.11-0.10.1.0\bin\windows 目录,然后在当前目录打开命令窗口
![](http://upload-images.jianshu.io/upload_images/2518871-4c3f5fa758d524a3.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
输入下面命令,创建一个topic
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test.topic
如果还遇到无法加载类等错误,还是先设置CLASSPATH
![](http://upload-images.jianshu.io/upload_images/2518871-fbfbf4c586577c80.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
遇到无法加载主类,需要设置CLASSPATH
![](http://upload-images.jianshu.io/upload_images/2518871-e4471d15c7cf6ffc.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
topic创建成功
打开一个Producer
kafka-console-producer.bat --broker-list localhost:9092 --topic test.topic
![](http://upload-images.jianshu.io/upload_images/2518871-4c86c781ef1bf19b.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
执行命令,打开生产者
这三个窗口不关闭的情况下(zookeeper/kafka/producer),再次开启一个命令窗口(还是在kafka目录右键打开),输入下面命令,开启Consumer
kafka-console-consumer.bat --zookeeper localhost:2181 --topic test.topic
![](http://upload-images.jianshu.io/upload_images/2518871-e53e11f4e6745fbc.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
这样,这里就有4个命令窗口
![](http://upload-images.jianshu.io/upload_images/2518871-480b67a8ff96acc2.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
分别是
Zookeeper
Kafka
Producer
Consumer
下面,我们在3号窗口(Producer)输入一些字符,就会看到4号窗口马上就收到消息
![](http://upload-images.jianshu.io/upload_images/2518871-cc9942c69733fee0.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
至此,Kafka的Windows单机环境搭建完毕
作者:sphsyv
链接:http://www.jianshu.com/p/64d25dcf8300
來源:简书
著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。
相关文章推荐
- Windows单机配置Kafka环境
- Windows单机配置Kafka环境
- Windows 环境下 Zookeeper 单机 下载、配置、启动和简单命令
- Windows单机配置Zookeeper环境
- Windows下Spark单机环境配置
- Windows单机配置Zookeeper环境
- Windows环境下solrCloud 6.x的配置安装(单机模拟多服务器) - solrClound部署
- Windows单机配置Zookeeper环境
- Windows单机环境下配置MySQL多实例
- windows环境下solrcloud的配置安装(单机模拟多服务器)
- Windows环境下solrCloud 6.x的配置安装(单机模拟多服务器) - 配置IK-Analyzer分词器
- MySQL主从复制配置-windows单机环境
- Windows环境下solrCloud 6.x的配置安装(单机模拟多服务器) - zookeeper部署
- Windows 环境下配置 Oracle 11gR2 Data Guard 手记
- windows下kafka源码阅读环境搭建
- Windows环境下配置oracle 11gR2 Data Guard详细过程
- 【PHP】配置windows 系统PHP系统环境变量
- Kinect for Windows SDK开发入门(一):开发环境配置
- windows下Qt5.1 for android开发环境配置
- 惊艳的cygwin——Windows下的Linux命令行环境的配置和使用