---

一站式Apache Kafka集群指标监控与运维管控平台

---

主要功能特性

集群监控维度

• 多版本集群管控，支持从0.10.2到2.4版本；
• 集群Topic、Broker等多维度历史与实时关键指标查看；

集群管控维度

• 集群运维，包括逻辑Region方式管理集群；
• Broker运维，包括优先副本选举；
• Topic运维，包括创建、查询、扩容、修改属性、数据采样及迁移等；
• 消费组运维，包括指定时间或指定偏移两种方式进行重置消费偏移；

用户使用维度

• 管理员用户与普通用户视角区分；
• 管理员用户与普通用户权限区分；

---

kafka-manager架构图

---

安装手册

环境依赖

• Maven 3.5.0+(后端打包依赖)
• node v8.12.0+(前端打包依赖)
• Java 8+(运行环境需要)
• MySQL 或 PostgreSQL(数据存储)

---

环境初始化

MySQL

执行create_mysql_table.sql中的SQL命令，从而创建所需的MySQL库及表，默认创建的库名是kafka_manager。

#############  示例：
mysql -uXXXX -pXXX -h XXX.XXX.XXX.XXX -PXXXX < ./create_mysql_table.sql

PostgreSQL

执行create_postgresql_table.sql中的SQL命令，从而创建所需的PostgreSQL表。

#############  示例：
psql -h XXX.XXX.XXX.XXX -U XXXX -d kafka_manager -f ./create_postgresql_table.sql

PostgreSQL 用户、数据库创建方式

create user admin encrypted password 'admin';
create database kafka_manager owner=admin template=template0 encoding='UTF-8' lc_collate='zh_CN.UTF-8' lc_ctype='zh_CN.UTF-8';

默认配置使用 MySQL 数据库，若要使用 PostgreSQL 数据库，使用 -Dspring.profiles.active=pg 指定 application-pg.yml 配置文件。

---

打包

执行mvn install命令即可。

备注：每一次执行mvn install命令，都将在web/src/main/resources/templates下面生成最新的前端资源文件，如果console模块下的代码没有变更，可以修改./pom.xml文件，忽略对console模块的打包。

---

启动

############# application.yml 是配置文件
cp web/src/main/resources/application.yml web/target/
cd web/target/
nohup java -jar kafka-manager-web-1.0.0-SNAPSHOT.jar --spring.config.location=./application.yml > /dev/null 2>&1 &

使用

本地启动的话，访问http://localhost:8080，输入帐号及密码进行登录。更多参考：kafka-manager使用手册

---

相关文档

• kafka-manager使用手册

钉钉交流群

搜索群号：32821440 或者扫码可入群交流. 备注：在钉钉搜索框搜索32821440，然后搜索结果中点击 "网络查找手机/邮箱/钉钉号" 即可看到我们的钉钉群：滴滴KafkaManager开源用户群。

项目成员

内部核心人员

iceyuhui、liuyaguang、limengmonty、zhangliangmike、nullhuangyiming、zengqiao、eilenexuzhe、huangjiaweihjw

外部贡献者

fangjunyu、zhoutaiyang

协议

kafka-manager基于Apache-2.0协议进行分发和使用，更多信息参见协议文件