这篇文章给大家介绍怎样开源Logi-KafkaManager，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。
github克隆比较慢gitee很快，采取前后端分离架构（springboot+reactJS+Typescript），代码包含了几个模块common，console，core，dao，extends，task，web，其中web中有MainApplication这个项目的启动类，其他都是依赖，console模块是基于recat+typescript的前端界面（技术栈选型还是很超前的），本地分别对前后端运行查看源码，这里把console单独放在VScode中运行；
# react跟vue一样基于node，所以npm相关依赖引入和配置启动
npm config set registry https://registry.npm.taobao.org
npm config list #查看npm当前配置
npm install
# 启动react项目
npm start
console前端模块启动运行：
因为前后端分别用idea和vscode，所以后端项目pom.xml需要注释掉对于console前端模块的引用：
依赖Maven 3.5+(后端打包)，node v12+(前端打包)，Java 8+(运行环境需要)，MySQL 5.7(数据存储)，node因为放在vscode了所以不需要，在mysql创建kafka_manager库，并且运行sql初始化语句，同时修改springboot中的mysql配置（这里官方提供的sql语句没有加字符集设置，需要加上不然报错）
mysql --default-character-set=utf8 -uroot -p123456 -P3306 -D kafka_manager < create_mysql_table.sql
将web模块的MainApplication.java配置成应用主类即可启动；
2021-01-25 19:33:22.642 INFO 18000 --- [ main] c.x.kafka.manager.web.MainApplication : MainApplication started
由于是本地运行，console模块的API的proxy/target需要修改：
proxy: {
'/api/v1/': {
target: 'http://127.0.0.1:8080',
//target: 'http://10.179.37.199:8008',
// target: 'http://99.11.45.164:8888',
changeOrigin: true,
}
以上，本地独立运行了基于前后端分离的调试环境；可以看见前端读取的是mysql库中kafka集群配置；
按照官方提供的功能架构图理解，因为logi-kafka-manager的定位是kafka集群全方位管控系统，它以kafka集群为主体，封装和集成了kafka对外提供的用户API，，以kafka集群和topic资源为运营对象，面向应用系统用户（topic使用者）、kafka/管控平台开发者、kafka/管控平台运维者提供便捷的资源管理能力。按照这个思维理解，官方给的功能架构包括：资源层（zk和mysql元数据存储）、引擎层（kafka集群为主体）、网关层（kafka服务基础管理能力）、服务层（高级用户api）、平台层（面向不同用户）；
这里在win系统下本地kafka+logi-kafka-manager的联调测试验证，用于对于kafka+logi-kafka-manager的源码研究和联调，关于win环境下如何部署zookeeper以及idea中运行kafka集群可以参考之前系列文章：《kafka实践（十二）：生产者（KafkaProducer）源码详解和调试》，环境配置如下：
本地测试增加kafka集群到logi-kafka-manager内进行统一管理，新增的本地集群的zk地址和kafka地址，就可以统一管理broker和topic，以及后续的资源分配，win下实现环境配置方便源码调整和kafka/管控平台人员的调试；
linux环境下的生产部署使用则更为简单，zk和kafka部署完成后，按照官方文档指引进行前后端统一部署，不再验证；
# mvn会调用npm模块下载node依赖
mvn install
# application.yml 是配置文件
cp kafka-manager-web/src/main/resources/application.yml kafka-manager-web/target/
cd kafka-manager-web/target/
nohup java -jar kafka-manager-web-2.1.0-SNAPSHOT.jar --spring.config.location=./application.yml > /dev/null 2>&1 &
针对应用开发人员，只关心其当前的应用系统的数据（多为日志数据）应发到哪个集群下的哪个topic？，因此logi-kafka-manager提供了“Topic管理”--“集群管理”--“监控告警”应用菜单服务，能提供以下几种服务：
创建/申请应用
在“Topic管理”内对当前的申请应用，匹配需要使用的topic资源（可调整配额和分区）
kafka集群接入申请
在“监控告警”内自定义告警规则；（对消费偏移量、消费速率、集群状态、topic状态进行自定义监控，并实时预警，太有用了！）
资源申请服务
针对kafka/管控开发人员，需要进行应用系统、kafka集群、kafka管控平台的综合管理，增加“运维管控”菜单，提供对于kafka集群的server.config配置等集群运维能力和用户计费账单管理能力，能提供以下几种服务：
针对kafka/管控运维人员，需要及时发现解决kafka集群问题和快速修复，提供“专家服务”，罗列常见问题和解决方法，提供以下几种服务：
对于logi-kafka-manager工具，期待整合Mirror-maker跨机房数据传输工具，更方便地配置数据实时传输和效率监控！
关于怎样开源Logi-KafkaManager就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
