Kafuka-windows环境搭建流程说明
一、安装JDK
1.JDK下载路:
http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html
2.按照: https://blog.csdn.net/zhys0902/article/details/79499329
参考步骤,依次配置JAVA_HOME、Classpath和Path,然后打开cmd,运行java -version成功,则JDK配置成功;
二、安装Zookeeper
由于Kafka的运行依赖于Zookeeper,所以在运行Kafka之前需要安装并运行Zookeeper
1.Zookeeper下载路径 http://zookeeper.apache.org/releases.html#download
2.解压到文件下(我的目录是D:Program Fileszookeeper-3.5.4-beta)
3.打开D:Program Fileszookeeper-3.5.4-betaconf,复制zoo_sample.cfg重命名成zoo.cfg
4.编辑zoo.cfg,修改dataDir为【dataDir=/zookeeper-3.5.4-beta /data】
5.添加环境变量
ZOOKEEPER_HOME D:Program Fileszookeeper-3.5.4-beta
Path 在现有的值后面添加 ;%ZOOKEEPER_HOME%bin;
报错:JAVA_HOME is not set
6.手动设置
打开(新建一个记事本,将文件拖入其中)文件手动添加如下图所示Java路径:
set JAVA=C:Program FilesJavajdk1.8.0_211binjava
set JAVA_HOME=C:Program FilesJavajdk1.8.0_211
7. 再次运行发现 8080端口被占用,在zoo.cfg增加admin.serverPort=8888 其中8888为未使用的端口
8.修改端口:
dataDir=D:Program Fileszookeeper-3.5.4-betadata
dataLogDir=D:Program Fileszookeeper-3.5.4-betalog
clientPort=2181
admin.serverPort=8888
运行成功!!!
三、安装Kafka
1.Kafka下载路径 http://kafka.apache.org/downloads
我们现在编译好的包
2.解压文件(我的目录是D:kafka_2.11-2.2.0 【这里不要在Program Files等文件名之间有空格的目录下,不然一会执行会不识别路径】)
3.打开目录D:kafka_2.11-2.2.0 config下server.properties文件,把log.dirs修改为【log.dirs= D:kafka_2.11-2.2.0 kafka-logs】
- Kafka会按照默认,在9092端口上运行,并连接zookeeper的默认端口:2181。
运行:
重要:请确保在启动Kafka服务器前,Zookeeper实例已经准备好并开始运行。
在kafka安装目录下运行:
.binwindowskafka-server-start.bat .configserver.properties
四、测试
上面的Zookeeper和kafka一直打开
(1)、创建主题
在kafka安装目录下运行:
.binwindowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic linlin
注意不要关了这个窗口!
(2)创建生产者 (Producer)
进入目录D:kafka_2.11-2.2.0binwindows输入如下命令:
kafka-console-producer.bat --broker-list localhost:9092 --topic linlin
(3)创建消费者(Consumer)
kafka-console-consumer.bat --zookeeper localhost:2181 --topic linlin
报错 :
高版本的用以下语句
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic linlin --from-beginning
注意:不要关了这个“生产者”和“消费者”窗口!
注意:在“生产者”窗口中输入内容,最后记得回车
搞定!!!
五、 使用kafka-manager
官网下载的是源码,如果觉得麻烦,可以直接从下面地址下载编译好的 kafka-manager-1.3.3.7.zip。
链接: http://pan.baidu.com/s/1qY8sGoO 密码: ye7b
链接:https://pan.baidu.com/s/1twhwfILRo9ReCAYczd44Fw 密码:kjqh
注意:启动kafka-manager之前请先保证zookeeper和kafka服务是开启的
启动目录下:
运行 bin/kafka-manager
默认情况下端口为9000,你还可以通过下面的命令指定配置文件和端口:
bin/kafka-manager -Dconfig.file=/path/to/application.conf -Dhttp.port=8889
zkhosts 是zookeeper服务的端口
登录权限,默认为false,可以改为true
登录账号密码
登录成功:
新建监控集群或单机
C:UsersAdministrator>rd /s /q D:kafka-manager-1.3.3.7binapplication.home_IS_UNDEFINED
用到的好文章:
https://blog.csdn.net/dayonglove2018/article/details/106919643?biz_id=102&utm_term=kafka%E4%B8%8Ezookeeper%E5%88%86%E5%BC%80%E5%AE%89%E8%A3%85%E7%9A%84%E6%80%8E%E4%B9%88%E4%BD%BF%E7%94%A8&utm_medium=distribute.pc_search_result.none-task-blog-2allsobaiduweb~default-1-106919643&spm=1018.2118.3001.4187
https://download.csdn.net/download/w353595/12668251?ops_request_misc=&request_id=&biz_id=103&utm_term=Windows%E4%B8%8Bkafka%E6%90%AD%E5%BB%BA&utm_medium=distribute.pc_search_result.none-task-download-2downloadsobaiduweb~default-0-12668251.pc_v2_rank_dl_default&spm=1018.2226.3001.4451.2
windows 上 Kafka 运行环境安装
kafka的windows下使用
在Window下安装kafka-manager
windows 安装 kafka-manager 客户端管理工具
windows上安装kafka-manager
win10 c++ 操作kafka
C++编程中使用librdkafka库去连接kafka集群



