(1)下载
下载界面:https://kafka.apache.org/downloads
注:
起初在win10使用Kafka_2.13-3.0.0.tgz安装失败(可参见Stackoverflow相关问题),
故降级到Kafka_2.13_2.8.1.tgz,
具体Kafka_2.13-3.0.0.tgz安装错误提示如下:
(2)解压tgz
(3)修改配置文件中的数据、日志存储路径
可修改安装目录下config/zookeeper.properties和server.properties配置文件,
修改红框中的存储位置为合适的位置(默认为/tmp/…)
(4)启动Kafka(需依赖Zookeeper)
Kafka 3.0.0(及之前版本)还需依赖Zookeeper,
目前Kafka官方提供了KRaft方式(不依赖Zookeeper,Broker和集群管理一体化),
但是目前处于预览测试阶段,不适用于生产环境,
可持续关注KRrat发展(关于KRaft的使用可参见安装包中config/kraft/README.md)。
在linux环境可以直接执行bin/*.sh脚本,如下:
# 首先启动Zookeeper服务 bin/zookeeper-server-start.sh config/zookeeper.properties # 然后在新窗口启动Kafka broker服务 bin/kafka-server-start.sh config/server.properties
在windows环境需执行bin/windows/*.bat脚本,如下:
# 进入到安装目录bin/windows子目录 cd bin/windows # 首先启动Zookeeper服务 zookeeper-server-start.bat ../../config/zookeeper.properties # 然后在新窗口启动Kafka broker服务 kafka-server-start.bat ../../config/server.properties
注:
由于启动kafka需要进入到windows指定目录下执行bat脚本,每次重复此 *** 作有些麻烦,
所以可以配合使用本地Xshell软件:
- LOCAL协议会话,
- 结合登录脚本指定全路径启动脚本命令
之后只要打开指定本地会话即可自动启动相关脚本。
具体的xshell全路径登录脚本如下(可结合实际安装路径进行调整):
# 启动zookeeper D:/programs/kafka_2.13-2.8.1/bin/windows/zookeeper-server-start.bat D:/programs/kafka_2.13-2.8.1/config/zookeeper.properties # 启动kafka-server D:/programs/kafka_2.13-2.8.1/bin/windows/kafka-server-start.bat D:/programs/kafka_2.13-2.8.1/config/server.properties
(5)程序连接Kafka
Zookeeper连接URL:localhost:2181
Kafka连接URL:localhost:9092
(6)安装Zookeeper、Kafka管理工具
使用了Idea开发工具中的插件:zoolytic, kafkalytic
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)