一站式Kafka平台解决方案——KafkaCenter (3)

不用docker

$ git clone https://github.com/xaecbd/KafkaCenter.git $ cd KafkaCenter $ mvn clean package -Dmaven.test.skip=true $ cd KafkaCenter\KafkaCenter-Core\target $ java -jar KafkaCenter-Core-2.1.0-SNAPSHOT.jar 4、查看

访问:8080 管理员用户与密码默认：admin / admin

功能介绍

Topics

用户可以在此模块完成Topic查看，已经申请新建Topic，同时可以对Topic进行生产消费测试。

Monitor

用户可以在此模块中可以查看Topic的生成以及消费情况，同时可以针对消费延迟情况设置预警信息。

Alerts

此模块用于维护预警信息。用户可以看到自己所有预警信息，管理员可以看到所有人的预警信息。

Kafka Connect

实现用户快速创建自己的Connect Job，并对自己的Connect进行维护。

KSQL

实现用户快速创建自己的KSQL Job，并对自己的Job进行维护。

Approve

此模块主要用于当普通用户申请创建Topic 或者Job时，管理员进行审批操作。

Setting

此模块主要功能为管理员维护User、Team以及kafka cluster信息

Cluster Manager

此模块用于管理员对集群的正常维护操作。

Home

这里是一些基本的统计信息

My Favorite

集群与topic列表

Topic

这里是一些topic的管理功能

Topic List

操作范围：

用户所属Team的所有Topic

Topic -> Topic List -> Detail 查看Topic的详细信息

Topic -> Topic List -> Mock 对Topic进行生产测试

申请创建topic

Important: admin不能申请task,普通用户必须先让管理员新建team后，将用户加入指定team后，才可以申请task。

操作范围：

用户所属Team的所有Task

Topic -> My Task -> Detail 查看申请的Task信息

Topic -> My Task -> Delete 删除被拒绝或待审批的Task

Topic -> My Task -> Edit 修改被拒绝的Task

Topic -> My Task -> Create Topic Task 创建Task

按照表单各字段要求填写信息

点击确认，提交申请

审批结果：

审批通过：Topic将会被创建在管理员指定的集群

审批拒绝：用户收到邮件，返回到My Task，点击对应Task后面的Edit，针对审批意见进行修改

Topic命名规则：

只能包含：数字、大小写字母、下划线、中划线、点；长度大于等于3小于等于100。

不推荐：下划线开头；

可对所有Topic进行消费测试

Monitor

监控模块

生产者监控

消费者监控

消息积压