“ 号称Kafka灵魂伴侣的滴滴Logi-KafkaManger”
搭建kafka集群的方法可参考:Kafka集群搭建
可参考这篇文章了解滴滴Logi-KafkaManger的设计理念和使用说明Kafka的灵魂伴侣滴滴Logi-KafkaManger
1. 两种部署方式
1.1 下载jar包
jar包下载地址:
https://github.com/didi/Logi-KafkaManager/releases/tag/v2.4.0
解压到本机或者服务器上之后
在MySQL中执行create_mysql_table.sql文件,创建数据库和数据表
默认创建的库名是logi_kafka_manager
修改application.yml文件,配置数据库地址以及用户名和密码
然后再jar所在路径执行命令启动程序
#linxu系统下执行
nohup java -jar kafka-manager.jar --spring.config.location=./application.yml &
#windows系统下执行
java -jar kafka-manager.jar --spring.config.location=C:\Users\daijiyong\Desktop\kafka-manager-2.4.0\application.yml &
本地启动的话,访问http://localhost:8080,输入帐号及密码(默认admin/admin)进行登录
服务端启动的话,访问http://{服务器ip}:8080
1.2 源码编译
源码地址:https://github.com/didi/logi-kafkamanager
本机需要Java8+、maven3.5+、node10+、MySQL5.7+的环境
通过idea将代码clone下来之后,打开kafka-manager-web模块的application.yml文件,修改数据库配置信息
运行该模块下的主函数MainApplication
启动成功后浏览器访问http://localhost:8080
2.连接并监控管理集群
下边这张图基本能介绍清楚滴滴Logi-KafkaManger的设计理念,这也有助于我们更好地使用系统
进入管理平台后点击运维管理并点击接入集群
给物理集群起一个名字,然后数据zookeeper和kafka的集群地址,中间用逗号隔开,点击确认
点击接入的物理集群,选择Region信息,点击新增Region按钮
给Region起一个名字,选择集群,并配置brokerid名,用逗号隔开
新建用户,或者使用当前用户点击顶部Topic管理导航,点击申请topic按钮
选择对应的信息,定义一个topic名称点击确定
然后使用admin用户进行审批,通过之后就能在topic管理中监控kafka的使用情况了
至此搭建成功。
更多详细的使用介绍可点击原文链接查看项目开源页面
文/戴先生@2021年5月16日
---end---
更多精彩推荐