README.md
    ![kafka-manager-logo](doc/assets/images/common/logo_name.png)
    
    **一站式`Apache Kafka`集群指标监控与运维管控平台**

    主要功能特性

    集群监控维度

    • 多版本集群管控,支持从0.10.22.4版本;
    • 集群Topic、Broker等多维度历史与实时关键指标查看;

    集群管控维度

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

    用户使用维度

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

    kafka-manager架构图

    kafka-manager-arch


    安装手册

    环境依赖

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

    环境初始化

    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.1.0-SNAPSHOT.jar --spring.config.location=./application.yml > /dev/null 2>&1 &

    使用

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


    相关文档

    钉钉交流群

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

    dingding_group

    项目成员

    内部核心人员

    iceyuhuiliuyaguanglimengmontyzhangliangmikenullhuangyimingzengqiaoeilenexuzhehuangjiaweihjw

    外部贡献者

    fangjunyuzhoutaiyang

    协议

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

    项目简介

    一站式云原生实时流数据平台,通过0侵入、插件化构建企业级Kafka服务,极大降低操作、存储和管理实时流数据门槛

    🚀 Github 镜像仓库 🚀

    源项目地址

    https://github.com/didi/kafka-manager

    发行版本 22

    v3.3.0

    全部发行版

    贡献者 88

    全部贡献者

    开发语言

    • Java 65.4 %
    • TypeScript 28.2 %
    • Less 3.2 %
    • Shell 1.3 %
    • Python 1.0 %