删除无效的publish

.github/ISSUE_TEMPLATE/bug_report.md

@@ -1,51 +0,0 @@
----
-name: 报告Bug
-about: 报告KnowStreaming的相关Bug
-title: ''
-labels: bug
-assignees: ''
-
----
-
-- [ ] 我已经在 [issues](https://github.com/didi/KnowStreaming/issues) 搜索过相关问题了,并没有重复的。
-
- 你是否希望来认领这个Bug。
-
- 「   Y   /   N  」
-
-### 环境信息
-
-* KnowStreaming version :   <font size=4 color =red>   xxx </font>
-* Operating System version :  <font size=4 color =red> xxx </font>
-* Java version : <font size=4 color =red> xxx </font>
-
-
-### 重现该问题的步骤
-
-1. xxx
-   
-
-
-2. xxx
-   
-
-3. xxx
-
-
-
-### 预期结果
-
-<!-- 写下应该出现的预期结果？-->
-
-### 实际结果
-
-<!-- 实际发生了什么? -->
-
-
----
-
-如果有异常，请附上异常Trace:
-
-```
-Just put your stack trace here!
-```

.github/ISSUE_TEMPLATE/config.yml

@@ -1,8 +0,0 @@
-blank_issues_enabled: true
-contact_links:
-  - name: 讨论问题
-    url: https://github.com/didi/KnowStreaming/discussions/new
-    about: 发起问题、讨论 等等
-  - name: KnowStreaming官网
-    url: https://knowstreaming.com/
-    about: KnowStreaming website

.github/ISSUE_TEMPLATE/detail_optimizing.md

@@ -1,26 +0,0 @@
----
-name: 优化建议
-about: 相关功能优化建议
-title: ''
-labels: Optimization Suggestions
-assignees: ''
-
----
-
-- [ ] 我已经在 [issues](https://github.com/didi/KnowStreaming/issues) 搜索过相关问题了,并没有重复的。
-
- 你是否希望来认领这个优化建议。
-
- 「   Y   /   N  」
-
-### 环境信息
-
-* KnowStreaming version :   <font size=4 color =red>   xxx </font>
-* Operating System version :  <font size=4 color =red> xxx </font>
-* Java version : <font size=4 color =red> xxx </font>
-
-### 需要优化的功能点
-
-
-### 建议如何优化
-

.github/ISSUE_TEMPLATE/feature_request.md

@@ -1,20 +0,0 @@
----
-name: 提议新功能/需求
-about: 给KnowStreaming提一个功能需求
-title: ''
-labels: feature
-assignees: ''
-
----
-
-- [ ] 我在 [issues](https://github.com/didi/KnowStreaming/issues) 中并未搜索到与此相关的功能需求。
-- [ ] 我在 [release note](https://github.com/didi/KnowStreaming/releases) 已经发布的版本中并没有搜到相关功能.
-
-你是否希望来认领这个Feature。
-
-「   Y   /   N  」
-
-
-## 这里描述需求
-<!--请尽可能的描述清楚您的需求 -->
-

.github/ISSUE_TEMPLATE/question.md

@@ -1,12 +0,0 @@
----
-name: 提个问题
-about: 问KnowStreaming相关问题
-title: ''
-labels: question
-assignees: ''
-
----
-
-- [ ] 我已经在 [issues](https://github.com/didi/KnowStreaming/issues) 搜索过相关问题了,并没有重复的。
-
-## 在这里提出你的问题

.github/PULL_REQUEST_TEMPLATE.md

@@ -1,23 +0,0 @@
-请不要在没有先创建Issue的情况下创建Pull Request。
-
-## 变更的目的是什么
-
-XXXXX
-
-## 简短的更新日志
-
-XX
-
-## 验证这一变化
-
-XXXX
-
-请遵循此清单，以帮助我们快速轻松地整合您的贡献：
-
-* [ ] 一个 PR（Pull Request的简写）只解决一个问题，禁止一个 PR 解决多个问题；
-* [ ] 确保 PR 有对应的 Issue（通常在您开始处理之前创建），除非是书写错误之类的琐碎更改不需要 Issue ；
-* [ ] 格式化 PR 及 Commit-Log 的标题及内容，例如 #861 。PS：Commit-Log 需要在 Git Commit 代码时进行填写，在 GitHub 上修改不了；
-* [ ] 编写足够详细的 PR 描述，以了解 PR 的作用、方式和原因；
-* [ ] 编写必要的单元测试来验证您的逻辑更正。如果提交了新功能或重大更改，请记住在 test 模块中添加 integration-test；
-* [ ] 确保编译通过，集成测试通过；
-

.gitignore

@@ -1,116 +1,113 @@
-### Intellij ###
-# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion, Android Studio and Webstorm
-
-*.iml
-
-## Directory-based project format:
-.idea/
-# if you remove the above rule, at least ignore the following:
-
-# User-specific stuff:
-# .idea/workspace.xml
-# .idea/tasks.xml
-# .idea/dictionaries
-# .idea/shelf
-
-# Sensitive or high-churn files:
-.idea/dataSources.ids
-.idea/dataSources.xml
-.idea/sqlDataSources.xml
-.idea/dynamic.xml
-.idea/uiDesigner.xml
-
-
-# Mongo Explorer plugin:
-.idea/mongoSettings.xml
-
-## File-based project format:
-*.ipr
-*.iws
-
-## Plugin-specific files:
-
-# IntelliJ
-/out/
-
-# mpeltonen/sbt-idea plugin
-.idea_modules/
-
-# JIRA plugin
-atlassian-ide-plugin.xml
-
-# Crashlytics plugin (for Android Studio and IntelliJ)
-com_crashlytics_export_strings.xml
-crashlytics.properties
-crashlytics-build.properties
-fabric.properties
-
-
-### Java ###
-*.class
-
-# Mobile Tools for Java (J2ME)
-.mtj.tmp/
-
-# Package Files #
-*.jar
-*.war
-*.ear
-*.tar.gz
-
-# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
-hs_err_pid*
-
-
-### OSX ###
-.DS_Store
-.AppleDouble
-.LSOverride
-
-# Icon must end with two \r
-Icon
-
-
-# Thumbnails
-._*
-
-# Files that might appear in the root of a volume
-.DocumentRevisions-V100
-.fseventsd
-.Spotlight-V100
-.TemporaryItems
-.Trashes
-.VolumeIcon.icns
-
-# Directories potentially created on remote AFP share
-.AppleDB
-.AppleDesktop
-Network Trash Folder
-Temporary Items
-.apdisk
-
-/target
-target/
-*.log
-*.log.*
-*.bak
-*.vscode
-*/.vscode/*
-*/.vscode
-*/velocity.log*
-*/*.log
-*/*.log.*
-node_modules/
-node_modules/*
-workspace.xml
-/output/*
-.gitversion
-out/*
-dist/
-dist/*
-km-rest/src/main/resources/templates/
-*dependency-reduced-pom*
-#filter flattened xml
-*/.flattened-pom.xml
-.flattened-pom.xml
-*/*/.flattened-pom.xml
+### Intellij ###
+# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion, Android Studio and Webstorm
+
+*.iml
+
+## Directory-based project format:
+.idea/
+# if you remove the above rule, at least ignore the following:
+
+# User-specific stuff:
+# .idea/workspace.xml
+# .idea/tasks.xml
+# .idea/dictionaries
+# .idea/shelf
+
+# Sensitive or high-churn files:
+.idea/dataSources.ids
+.idea/dataSources.xml
+.idea/sqlDataSources.xml
+.idea/dynamic.xml
+.idea/uiDesigner.xml
+
+
+# Mongo Explorer plugin:
+.idea/mongoSettings.xml
+
+## File-based project format:
+*.ipr
+*.iws
+
+## Plugin-specific files:
+
+# IntelliJ
+/out/
+
+# mpeltonen/sbt-idea plugin
+.idea_modules/
+
+# JIRA plugin
+atlassian-ide-plugin.xml
+
+# Crashlytics plugin (for Android Studio and IntelliJ)
+com_crashlytics_export_strings.xml
+crashlytics.properties
+crashlytics-build.properties
+fabric.properties
+
+
+### Java ###
+*.class
+
+# Mobile Tools for Java (J2ME)
+.mtj.tmp/
+
+# Package Files #
+*.jar
+*.war
+*.ear
+*.tar.gz
+
+# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
+hs_err_pid*
+
+
+### OSX ###
+.DS_Store
+.AppleDouble
+.LSOverride
+
+# Icon must end with two \r
+Icon
+
+
+# Thumbnails
+._*
+
+# Files that might appear in the root of a volume
+.DocumentRevisions-V100
+.fseventsd
+.Spotlight-V100
+.TemporaryItems
+.Trashes
+.VolumeIcon.icns
+
+# Directories potentially created on remote AFP share
+.AppleDB
+.AppleDesktop
+Network Trash Folder
+Temporary Items
+.apdisk
+
+/target
+target/
+*.log
+*.log.*
+*.bak
+*.vscode
+*/.vscode/*
+*/.vscode
+*/velocity.log*
+*/*.log
+*/*.log.*
+node_modules/
+node_modules/*
+workspace.xml
+/output/*
+.gitversion
+node_modules/*
+out/*
+dist/
+dist/*
+kafka-manager-web/src/main/resources/templates/
+.DS_Store

CONTRIBUTING.md

@@ -0,0 +1,28 @@
+# Contribution Guideline
+
+Thanks for considering to contribute this project. All issues and pull requests are highly appreciated.
+
+## Pull Requests
+
+Before sending pull request to this project, please read and follow guidelines below.
+
+1. Branch: We only accept pull request on `dev` branch.
+2. Coding style: Follow the coding style used in kafka-manager.
+3. Commit message: Use English and be aware of your spell.
+4. Test: Make sure to test your code.
+
+Add device mode, API version, related log, screenshots and other related information in your pull request if possible.
+
+NOTE: We assume all your contribution can be licensed under the [Apache License 2.0](LICENSE).
+
+## Issues
+
+We love clearly described issues. :)
+
+Following information can help us to resolve the issue faster.
+
+* Device mode and hardware information.
+* API version.
+* Logs.
+* Screenshots.
+* Steps to reproduce the issue.

README.md

@@ -0,0 +1,64 @@
+
+---
+
+![kafka-manager-logo](./docs/assets/images/common/logo_name.png)
+
+**一站式`Apache Kafka`集群指标监控与运维管控平台**
+
+--- 
+
+## 主要功能特性
+
+
+### 集群监控维度
+
+- 多版本集群管控，支持从`0.10.2`到`2.x`版本；
+- 集群Topic、Broker等多维度历史与实时关键指标查看；
+
+
+### 集群管控维度
+
+- 集群运维，包括逻辑Region方式管理集群
+- Broker运维，包括优先副本选举
+- Topic运维，包括创建、查询、扩容、修改属性、数据采样及迁移等；
+- 消费组运维，包括指定时间或指定偏移两种方式进行重置消费偏移
+
+
+### 用户使用维度
+
+- Kafka用户、Kafka研发、Kafka运维 视角区分
+- Kafka用户、Kafka研发、Kafka运维 权限区分
+
+
+## kafka-manager架构图
+
+![kafka-manager-arch](./docs/assets/images/common/arch.png)
+
+
+## 相关文档
+
+- [kafka-manager 安装手册](docs/install_guide/install_guide_cn.md)
+- [kafka-manager 接入集群](docs/user_guide/add_cluster/add_cluster.md)
+- [kafka-manager 用户使用手册](docs/user_guide/user_guide_cn.md)
+- [kafka-manager FAQ](docs/user_guide/faq.md)
+
+## 钉钉交流群
+
+![dingding_group](./docs/assets/images/common/dingding_group.jpg)
+
+
+## 项目成员
+
+### 内部核心人员
+
+`iceyuhui`、`liuyaguang`、`limengmonty`、`zhangliangmike`、`nullhuangyiming`、`zengqiao`、`eilenexuzhe`、`huangjiaweihjw`
+
+
+### 外部贡献者
+
+`fangjunyu`、`zhoutaiyang`
+
+
+## 协议
+
+`kafka-manager`基于`Apache-2.0`协议进行分发和使用，更多信息参见[协议文件](./LICENSE)

build.sh

@@ -0,0 +1,91 @@
+#!/bin/bash
+workspace=$(cd $(dirname $0) && pwd -P)
+cd $workspace
+
+## constant
+app_name=kafka-manager
+output_dir=output
+
+gitversion=.gitversion
+control=./control.sh
+create_mysql_table=./docs/install_guide/create_mysql_table.sql
+app_config_file=./kafka-manager-web/src/main/resources/application.yml
+
+## function
+function build() {
+    # 进行编译
+#    # cmd 设置使用的JDK, 按需选择, 默认已安装了JDK 8
+#    JVERSION=`java -version 2>&1 | awk 'NR==1{gsub(/"/,"");print $3}'`
+#    major=`echo $JVERSION | awk -F. '{print $1}'`
+#    mijor=`echo $JVERSION | awk -F. '{print $2}'`
+#    if [ $major -le 1 ] && [ $mijor -lt 8 ]; then
+#        export JAVA_HOME=/usr/local/jdk1.8.0_65  #(使用jdk8请设置)
+#        export PATH=$JAVA_HOME/bin:$PATH
+#    fi
+
+    # 编译命令
+	mvn -U clean package -Dmaven.test.skip=true
+
+    local sc=$?
+    if [ $sc -ne 0 ];then
+    	## 编译失败, 退出码为 非0
+        echo "$app_name build error"
+        exit $sc
+    else
+        echo -n "$app_name build ok, vsn="`gitversion`
+    fi
+}
+
+function make_output() {
+	# 新建output目录
+	rm -rf $output_dir &>/dev/null
+	mkdir -p $output_dir &>/dev/null
+
+	# 填充output目录, output内的内容 即为 线上部署内容
+	(
+#        cp -rf $control $output_dir &&                 # 拷贝 control.sh 脚本    至output目录
+        cp -rf $create_mysql_table $output_dir &&       # 拷贝 sql 初始化脚本      至output目录
+        cp -rf $app_config_file $output_dir &&          # 拷贝 application.yml   至output目录
+
+        # 拷贝程序包到output路径
+		cp kafka-manager-web/target/${app_name}-*-SNAPSHOT.jar ${output_dir}/${app_name}.jar
+        echo -e "make output ok."
+	) || { echo -e "make output error"; exit 2; } # 填充output目录失败后, 退出码为 非0
+}
+
+function make_package() {
+	# 压缩output目录
+	(
+	    tar cvzf ${app_name}.tar.gz ${output_dir}
+        echo -e "make package ok."
+	) || { echo -e "make package error"; exit 2; } # 压缩output目录失败后, 退出码为 非0
+}
+
+## internals
+function gitversion() {
+    git log -1 --pretty=%h > $gitversion
+    local gv=`cat $gitversion`
+    echo "$gv"
+}
+
+
+##########################################
+## main
+## 其中,
+## 		1.进行编译
+##		2.生成部署包output
+##		3.生成tar.gz压缩包
+##########################################
+
+# 1.进行编译
+build
+
+# 2.生成部署包output
+make_output
+
+# 3.生成tar.gz压缩包
+make_package
+
+# 编译成功
+echo -e "build done"
+exit 0

docs/dev_guide/Intergration_n9e_monitor.md

@@ -0,0 +1,39 @@
+
+---
+
+![kafka-manager-logo](../assets/images/common/logo_name.png)
+
+**一站式`Apache Kafka`集群指标监控与运维管控平台**
+
+--- 
+
+# 夜莺监控集成
+
+- `Kafka-Manager`通过将 监控的数据 以及 监控的规则 都提交给夜莺，然后依赖夜莺的监控系统从而实现监控告警功能。
+
+- 监控数据上报 & 告警规则的创建等能力已经具备。但类似查看告警历史，告警触发时的监控数据等正在集成中(暂时可以到夜莺系统进行查看)，欢迎有兴趣的同学进行共建 或 贡献代码。
+
+## 1、配置说明
+
+```yml
+# 配置文件中关于监控部分的配置
+monitor:
+  enabled: false
+  n9e:
+    nid: 2
+    user-token: 123456
+    mon:
+      base-url: http://127.0.0.1:8032
+    sink:
+      base-url: http://127.0.0.1:8006
+    rdb:
+      base-url: http://127.0.0.1:80
+
+# enabled: 表示是否开启监控告警的功能, true: 开启, false: 不开启
+# n9e.nid: 夜莺的节点ID
+# n9e.user-token: 用户的密钥，在夜莺的个人设置中
+# n9e.mon.base-url: 监控地址
+# n9e.sink.base-url: 数据上报地址
+# n9e.rdb.base-url: 用户资源中心地址
+```
+

docs/dev_guide/use_mysql_8.md

@@ -0,0 +1,41 @@
+
+---
+
+![kafka-manager-logo](../assets/images/common/logo_name.png)
+
+**一站式`Apache Kafka`集群指标监控与运维管控平台**
+
+--- 
+
+# 使用`MySQL 8`
+
+感谢 [herry-hu](https://github.com/herry-hu) 提供的方案。
+
+
+当前因为无法同时兼容`MySQL 8`与`MySQL 5.7`，因此代码中默认的版本还是`MySQL 5.7`。
+
+
+当前如需使用`MySQL 8`，则续按照下述流程进行简单修改代码。
+
+
+- Step1. 修改application.yml中的MySQL驱动类
+```shell
+
+# 将driver-class-name后面的驱动类修改为:
+# driver-class-name: com.mysql.jdbc.Driver
+driver-class-name: com.mysql.cj.jdbc.Driver
+```
+
+
+- Step2. 修改MySQL依赖包
+```shell
+# 将根目录下面的pom.xml文件依赖的`MySQL`依赖包版本调整为
+
+<dependency>
+    <groupId>mysql</groupId>
+    <artifactId>mysql-connector-java</artifactId>
+#    <version>5.1.41</version>
+    <version>8.0.20</version>
+</dependency>
+```
+

docs/install_guide/create_mysql_table.sql

@@ -0,0 +1,582 @@
+--
+-- Table structure for table `account`
+--
+
+-- DROP TABLE IF EXISTS `account`;
+CREATE TABLE `account` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+  `username` varchar(128) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT '用户名',
+  `password` varchar(128) NOT NULL DEFAULT '' COMMENT '密码',
+  `role` tinyint(8) NOT NULL DEFAULT '0' COMMENT '角色类型, 0:普通用户 1:研发 2:运维',
+  `status` int(16) NOT NULL DEFAULT '0' COMMENT '0标识使用中，-1标识已废弃',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `gmt_modify` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_username` (`username`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='账号表';
+INSERT INTO account(username, password, role) VALUES ('admin', '21232f297a57a5a743894a0e4a801fc3', 2);
+
+--
+-- Table structure for table `app`
+--
+
+-- DROP TABLE IF EXISTS `app`;
+CREATE TABLE `app` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增id',
+  `app_id` varchar(128) NOT NULL DEFAULT '' COMMENT '应用id',
+  `name` varchar(192) NOT NULL DEFAULT '' COMMENT '应用名称',
+  `password` varchar(256) NOT NULL DEFAULT '' COMMENT '应用密码',
+  `type` int(11) NOT NULL DEFAULT '0' COMMENT '类型, 0:普通用户, 1:超级用户',
+  `applicant` varchar(64) NOT NULL DEFAULT '' COMMENT '申请人',
+  `principals` text COMMENT '应用负责人',
+  `description` text COMMENT '应用描述',
+  `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `modify_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_name` (`name`),
+  UNIQUE KEY `uniq_app_id` (`app_id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='应用信息';
+
+
+--
+-- Table structure for table `authority`
+--
+
+-- DROP TABLE IF EXISTS `authority`;
+CREATE TABLE `authority` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增id',
+  `app_id` varchar(128) NOT NULL DEFAULT '' COMMENT '应用id',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '0' COMMENT '集群id',
+  `topic_name` varchar(192) NOT NULL DEFAULT '' COMMENT 'topic名称',
+  `access` int(11) NOT NULL DEFAULT '0' COMMENT '0:无权限, 1:读, 2:写, 3:读写',
+  `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `modify_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_app_id_cluster_id_topic_name` (`app_id`,`cluster_id`,`topic_name`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='权限信息(kafka-manager)';
+
+--
+-- Table structure for table `broker`
+--
+
+-- DROP TABLE IF EXISTS `broker`;
+CREATE TABLE `broker` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '-1' COMMENT '集群id',
+  `broker_id` int(16) NOT NULL DEFAULT '-1' COMMENT 'brokerid',
+  `host` varchar(128) NOT NULL DEFAULT '' COMMENT 'broker主机名',
+  `port` int(16) NOT NULL DEFAULT '-1' COMMENT 'broker端口',
+  `timestamp` bigint(20) NOT NULL DEFAULT '-1' COMMENT '启动时间',
+  `max_avg_bytes_in` bigint(20) NOT NULL DEFAULT '-1' COMMENT '峰值的均值流量',
+  `version` varchar(128) NOT NULL DEFAULT '' COMMENT 'broker版本',
+  `status` int(16) NOT NULL DEFAULT '0' COMMENT '状态: 0有效，-1无效',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `gmt_modify` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_cluster_id_broker_id` (`cluster_id`,`broker_id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='broker信息表';
+
+--
+-- Table structure for table `broker_metrics`
+--
+
+-- DROP TABLE IF EXISTS `broker_metrics`;
+CREATE TABLE `broker_metrics` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增id',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '-1' COMMENT '集群id',
+  `broker_id` int(16) NOT NULL DEFAULT '-1' COMMENT 'brokerid',
+  `metrics` text COMMENT '指标',
+  `messages_in` double(53,2) NOT NULL DEFAULT '0.00' COMMENT '每秒消息数流入',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  PRIMARY KEY (`id`),
+  KEY `idx_cluster_id_broker_id_gmt_create` (`cluster_id`,`broker_id`,`gmt_create`),
+  KEY `idx_gmt_create` (`gmt_create`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='broker-metric信息表';
+
+--
+-- Table structure for table `cluster`
+--
+
+-- DROP TABLE IF EXISTS `cluster`;
+CREATE TABLE `cluster` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '集群id',
+  `cluster_name` varchar(128) NOT NULL DEFAULT '' COMMENT '集群名称',
+  `zookeeper` varchar(512) NOT NULL DEFAULT '' COMMENT 'zk地址',
+  `bootstrap_servers` varchar(512) NOT NULL DEFAULT '' COMMENT 'server地址',
+  `kafka_version` varchar(32) NOT NULL DEFAULT '' COMMENT 'kafka版本',
+  `security_properties` text COMMENT '安全认证参数',
+  `status` tinyint(4) NOT NULL DEFAULT '1' COMMENT ' 监控标记, 0表示未监控, 1表示监控中',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `gmt_modify` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_cluster_name` (`cluster_name`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='cluster信息表';
+
+--
+-- Table structure for table `cluster_metrics`
+--
+
+-- DROP TABLE IF EXISTS `cluster_metrics`;
+CREATE TABLE `cluster_metrics` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增id',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '0' COMMENT '集群id',
+  `metrics` text COMMENT '指标',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  PRIMARY KEY (`id`),
+  KEY `idx_cluster_id_gmt_create` (`cluster_id`,`gmt_create`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='clustermetrics信息';
+
+--
+-- Table structure for table `cluster_tasks`
+--
+
+-- DROP TABLE IF EXISTS `cluster_tasks`;
+CREATE TABLE `cluster_tasks` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增id',
+  `uuid` varchar(128) NOT NULL DEFAULT '' COMMENT '任务UUID',
+  `cluster_id` bigint(128) NOT NULL DEFAULT '-1' COMMENT '集群id',
+  `task_type` varchar(128) NOT NULL DEFAULT '' COMMENT '任务类型',
+  `kafka_package` text COMMENT 'kafka包',
+  `kafka_package_md5` varchar(128) NOT NULL DEFAULT '' COMMENT 'kafka包的md5',
+  `server_properties` text COMMENT 'kafkaserver配置',
+  `server_properties_md5` varchar(128) NOT NULL DEFAULT '' COMMENT '配置文件的md5',
+  `agent_task_id` bigint(128) NOT NULL DEFAULT '-1' COMMENT '任务id',
+  `agent_rollback_task_id` bigint(128) NOT NULL DEFAULT '-1' COMMENT '回滚任务id',
+  `host_list` text COMMENT '升级的主机',
+  `pause_host_list` text COMMENT '暂停点',
+  `rollback_host_list` text COMMENT '回滚机器列表',
+  `rollback_pause_host_list` text COMMENT '回滚暂停机器列表',
+  `operator` varchar(64) NOT NULL DEFAULT '' COMMENT '操作人',
+  `task_status` int(11) NOT NULL DEFAULT '0' COMMENT '任务状态',
+  `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `modify_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='集群任务(集群升级部署)';
+
+--
+-- Table structure for table `config`
+--
+
+-- DROP TABLE IF EXISTS `config`;
+CREATE TABLE `config` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+  `config_key` varchar(128) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT '配置key',
+  `config_value` text COMMENT '配置value',
+  `config_description` text COMMENT '备注说明',
+  `status` int(16) NOT NULL DEFAULT '0' COMMENT '0标识使用中，-1标识已废弃',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `gmt_modify` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_config_key` (`config_key`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='配置表';
+
+--
+-- Table structure for table `controller`
+--
+
+-- DROP TABLE IF EXISTS `controller`;
+CREATE TABLE `controller` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增id',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '-1' COMMENT '集群id',
+  `broker_id` int(16) NOT NULL DEFAULT '-1' COMMENT 'brokerid',
+  `host` varchar(256) NOT NULL DEFAULT '' COMMENT '主机名',
+  `timestamp` bigint(20) NOT NULL DEFAULT '-1' COMMENT 'controller变更时间',
+  `version` int(16) NOT NULL DEFAULT '-1' COMMENT 'controller格式版本',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_cluster_id_broker_id_timestamp` (`cluster_id`,`broker_id`,`timestamp`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='controller记录表';
+
+--
+-- Table structure for table `gateway_config`
+--
+
+-- DROP TABLE IF EXISTS `gateway_config`;
+CREATE TABLE `gateway_config` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+  `type` varchar(128) NOT NULL DEFAULT '' COMMENT '配置类型',
+  `name` varchar(128) NOT NULL DEFAULT '' COMMENT '配置名称',
+  `value` text COMMENT '配置值',
+  `version` bigint(20) unsigned NOT NULL DEFAULT '0' COMMENT '版本信息',
+  `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `modify_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_type_name` (`type`,`name`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='gateway配置';
+INSERT INTO gateway_config(type, name, value, `version`) values('SERVICE_DISCOVERY_QUEUE_SIZE', 'SERVICE_DISCOVERY_QUEUE_SIZE', 100000000, 1);
+INSERT INTO gateway_config(type, name, value, `version`) values('SERVICE_DISCOVERY_APPID_RATE', 'SERVICE_DISCOVERY_APPID_RATE', 100000000, 1);
+INSERT INTO gateway_config(type, name, value, `version`) values('SERVICE_DISCOVERY_IP_RATE', 'SERVICE_DISCOVERY_IP_RATE', 100000000, 1);
+INSERT INTO gateway_config(type, name, value, `version`) values('SERVICE_DISCOVERY_SP_RATE', 'app_01234567', 100000000, 1);
+INSERT INTO gateway_config(type, name, value, `version`) values('SERVICE_DISCOVERY_SP_RATE', '192.168.0.1', 100000000, 1);
+
+--
+-- Table structure for table `heartbeat`
+--
+
+-- DROP TABLE IF EXISTS `heartbeat`;
+CREATE TABLE `heartbeat` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+  `ip` varchar(128) NOT NULL DEFAULT '' COMMENT '主机ip',
+  `hostname` varchar(256) NOT NULL DEFAULT '' COMMENT '主机名',
+  `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `modify_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_ip` (`ip`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='心跳信息';
+
+--
+-- Table structure for table `kafka_acl`
+--
+
+-- DROP TABLE IF EXISTS `kafka_acl`;
+CREATE TABLE `kafka_acl` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增id',
+  `app_id` varchar(128) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT '用户id',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '0' COMMENT '集群id',
+  `topic_name` varchar(192) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT 'topic名称',
+  `access` int(11) NOT NULL DEFAULT '0' COMMENT '0:无权限, 1:读, 2:写, 3:读写',
+  `operation` int(11) NOT NULL DEFAULT '0' COMMENT '0:创建, 1:更新 2:删除, 以最新的一条数据为准',
+  `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='权限信息(kafka-broker)';
+
+--
+-- Table structure for table `kafka_bill`
+--
+
+-- DROP TABLE IF EXISTS `kafka_bill`;
+CREATE TABLE `kafka_bill` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '0' COMMENT '集群id',
+  `topic_name` varchar(192) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT 'topic名称',
+  `principal` varchar(64) NOT NULL DEFAULT '' COMMENT '负责人',
+  `quota` double(53,2) NOT NULL DEFAULT '0.00' COMMENT '配额, 单位mb/s',
+  `cost` double(53,2) NOT NULL DEFAULT '0.00' COMMENT '成本, 单位元',
+  `cost_type` int(16) NOT NULL DEFAULT '0' COMMENT '成本类型, 0:共享集群, 1:独享集群, 2:独立集群',
+  `gmt_day` varchar(64) NOT NULL DEFAULT '' COMMENT '计价的日期, 例如2019-02-02的计价结果',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_cluster_id_topic_name_gmt_day` (`cluster_id`,`topic_name`,`gmt_day`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='kafka账单';
+
+--
+-- Table structure for table `kafka_file`
+--
+
+-- DROP TABLE IF EXISTS `kafka_file`;
+CREATE TABLE `kafka_file` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增id',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '-1' COMMENT '集群id',
+  `storage_name` varchar(128) NOT NULL DEFAULT '' COMMENT '存储位置',
+  `file_name` varchar(128) NOT NULL DEFAULT '' COMMENT '文件名',
+  `file_md5` varchar(256) NOT NULL DEFAULT '' COMMENT '文件md5',
+  `file_type` int(16) NOT NULL DEFAULT '-1' COMMENT '0:kafka压缩包, 1:kafkaserver配置',
+  `description` text COMMENT '备注信息',
+  `operator` varchar(64) NOT NULL DEFAULT '' COMMENT '创建用户',
+  `status` int(16) NOT NULL DEFAULT '0' COMMENT '状态, 0:正常, -1:删除',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `gmt_modify` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_cluster_id_file_name_storage_name` (`cluster_id`,`file_name`,`storage_name`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='文件管理';
+
+--
+-- Table structure for table `kafka_user`
+--
+
+-- DROP TABLE IF EXISTS `kafka_user`;
+CREATE TABLE `kafka_user` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增id',
+  `app_id` varchar(128) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT '应用id',
+  `password` varchar(256) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT '密码',
+  `user_type` int(11) NOT NULL DEFAULT '0' COMMENT '0:普通用户, 1:超级用户',
+  `operation` int(11) NOT NULL DEFAULT '0' COMMENT '0:创建, 1:更新 2:删除, 以最新一条的记录为准',
+  `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='kafka用户表';
+INSERT INTO app(app_id, name, password, type, applicant, principals, description) VALUES ('dkm_admin', 'KM管理员', 'km_kMl4N8as1Kp0CCY', 1, 'admin', 'admin', 'KM管理员应用-谨慎对外提供');
+INSERT INTO kafka_user(app_id, password, user_type, operation) VALUES ('dkm_admin', 'km_kMl4N8as1Kp0CCY', 1, 0);
+
+
+--
+-- Table structure for table `logical_cluster`
+--
+
+-- DROP TABLE IF EXISTS `logical_cluster`;
+CREATE TABLE `logical_cluster` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+  `name` varchar(192) NOT NULL DEFAULT '' COMMENT '逻辑集群名称',
+  `mode` int(16) NOT NULL DEFAULT '0' COMMENT '逻辑集群类型, 0:共享集群, 1:独享集群, 2:独立集群',
+  `app_id` varchar(64) NOT NULL DEFAULT '' COMMENT '所属应用',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '-1' COMMENT '集群id',
+  `region_list` varchar(256) NOT NULL DEFAULT '' COMMENT 'regionid列表',
+  `description` text COMMENT '备注说明',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `gmt_modify` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_name` (`name`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='逻辑集群信息表';
+
+--
+-- Table structure for table `monitor_rule`
+--
+
+-- DROP TABLE IF EXISTS `monitor_rule`;
+CREATE TABLE `monitor_rule` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增id',
+  `name` varchar(192) NOT NULL DEFAULT '' COMMENT '告警名称',
+  `strategy_id` bigint(20) NOT NULL DEFAULT '-1' COMMENT '监控id',
+  `app_id` varchar(64) NOT NULL DEFAULT '' COMMENT 'appid',
+  `operator` varchar(64) NOT NULL DEFAULT '' COMMENT '操作人',
+  `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `modify_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_name` (`name`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='监控规则';
+
+--
+-- Table structure for table `operate_record`
+--
+
+-- DROP TABLE IF EXISTS `operate_record`;
+CREATE TABLE `operate_record` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+  `module_id` int(16) NOT NULL DEFAULT '-1' COMMENT '模块类型, 0:topic, 1:应用, 2:配额, 3:权限, 4:集群, -1:未知',
+  `operate_id` int(16) NOT NULL DEFAULT '-1' COMMENT '操作类型, 0:新增, 1:删除, 2:修改',
+  `resource` varchar(256) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT 'topic名称、app名称',
+  `content` text COMMENT '操作内容',
+  `operator` varchar(64) NOT NULL DEFAULT '' COMMENT '操作人',
+  `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `modify_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`),
+  KEY `idx_module_id_operate_id_operator` (`module_id`,`operate_id`,`operator`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='操作记录';
+
+--
+-- Table structure for table `reassign_task`
+--
+
+-- DROP TABLE IF EXISTS `reassign_task`;
+CREATE TABLE `reassign_task` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增id',
+  `task_id` bigint(20) NOT NULL DEFAULT '-1' COMMENT '任务ID',
+  `name` varchar(256) NOT NULL DEFAULT '' COMMENT '任务名称',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '0' COMMENT '集群id',
+  `topic_name` varchar(192) NOT NULL DEFAULT '' COMMENT 'Topic名称',
+  `partitions` text COMMENT '分区',
+  `reassignment_json` text COMMENT '任务参数',
+  `real_throttle` bigint(20) NOT NULL DEFAULT '0' COMMENT '限流值',
+  `max_throttle` bigint(20) NOT NULL DEFAULT '0' COMMENT '限流上限',
+  `min_throttle` bigint(20) NOT NULL DEFAULT '0' COMMENT '限流下限',
+  `begin_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '开始时间',
+  `operator` varchar(64) NOT NULL DEFAULT '' COMMENT '操作人',
+  `description` varchar(256) NOT NULL DEFAULT '' COMMENT '备注说明',
+  `status` int(16) NOT NULL DEFAULT '0' COMMENT '任务状态',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '任务创建时间',
+  `gmt_modify` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '任务修改时间',
+  `original_retention_time` bigint(20) NOT NULL DEFAULT '86400000' COMMENT 'Topic存储时间',
+  `reassign_retention_time` bigint(20) NOT NULL DEFAULT '86400000' COMMENT '迁移时的存储时间',
+  `src_brokers` text COMMENT '源Broker',
+  `dest_brokers` text COMMENT '目标Broker',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='topic迁移信息';
+
+--
+-- Table structure for table `region`
+--
+
+-- DROP TABLE IF EXISTS `region`;
+CREATE TABLE `region` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+  `name` varchar(192) NOT NULL DEFAULT '' COMMENT 'region名称',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '-1' COMMENT '集群id',
+  `broker_list` varchar(256) NOT NULL DEFAULT '' COMMENT 'broker列表',
+  `capacity` bigint(20) NOT NULL DEFAULT '0' COMMENT '容量(B/s)',
+  `real_used` bigint(20) NOT NULL DEFAULT '0' COMMENT '实际使用量(B/s)',
+  `estimate_used` bigint(20) NOT NULL DEFAULT '0' COMMENT '预估使用量(B/s)',
+  `description` text COMMENT '备注说明',
+  `status` int(16) NOT NULL DEFAULT '0' COMMENT '状态，0正常，1已满',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `gmt_modify` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_name` (`name`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='region信息表';
+
+--
+-- Table structure for table `topic`
+--
+
+-- DROP TABLE IF EXISTS `topic`;
+CREATE TABLE `topic` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '-1' COMMENT '集群id',
+  `topic_name` varchar(192) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT 'topic名称',
+  `app_id` varchar(64) NOT NULL DEFAULT '' COMMENT 'topic所属appid',
+  `peak_bytes_in` bigint(20) NOT NULL DEFAULT '0' COMMENT '峰值流量',
+  `description` text COMMENT '备注信息',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `gmt_modify` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_cluster_id_topic_name` (`cluster_id`,`topic_name`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='topic信息表';
+
+--
+-- Table structure for table `topic_app_metrics`
+--
+
+-- DROP TABLE IF EXISTS `topic_app_metrics`;
+CREATE TABLE `topic_app_metrics` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '0' COMMENT '集群id',
+  `topic_name` varchar(192) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT 'topic名称',
+  `app_id` varchar(64) NOT NULL DEFAULT '' COMMENT 'appid',
+  `metrics` text COMMENT '指标',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  PRIMARY KEY (`id`),
+  KEY `idx_cluster_id_topic_name_app_id_gmt_create` (`cluster_id`,`topic_name`,`app_id`,`gmt_create`),
+  KEY `idx_gmt_create` (`gmt_create`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='topic app metrics';
+
+--
+-- Table structure for table `topic_connections`
+--
+
+-- DROP TABLE IF EXISTS `topic_connections`;
+CREATE TABLE `topic_connections` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+  `app_id` varchar(64) NOT NULL DEFAULT '' COMMENT '应用id',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '0' COMMENT '集群id',
+  `topic_name` varchar(192) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT 'topic名称',
+  `type` varchar(16) NOT NULL DEFAULT '' COMMENT 'producer or consumer',
+  `ip` varchar(32) NOT NULL DEFAULT '' COMMENT 'ip地址',
+  `client_version` varchar(8) NOT NULL DEFAULT '' COMMENT '客户端版本',
+  `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_app_id_cluster_id_topic_name_type_ip_client_version` (`app_id`,`cluster_id`,`topic_name`,`type`,`ip`,`client_version`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='topic连接信息表';
+
+--
+-- Table structure for table `topic_expired`
+--
+
+-- DROP TABLE IF EXISTS `topic_expired`;
+CREATE TABLE `topic_expired` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '-1' COMMENT '集群id',
+  `topic_name` varchar(192) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT 'topic名称',
+  `produce_connection_num` bigint(20) NOT NULL DEFAULT '0' COMMENT '发送连接数',
+  `fetch_connection_num` bigint(20) NOT NULL DEFAULT '0' COMMENT '消费连接数',
+  `expired_day` bigint(20) NOT NULL DEFAULT '0' COMMENT '过期天数',
+  `gmt_retain` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '保留截止时间',
+  `status` int(16) NOT NULL DEFAULT '0' COMMENT '-1:可下线, 0:过期待通知, 1+:已通知待反馈',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `gmt_modify` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_cluster_id_topic_name` (`cluster_id`,`topic_name`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='topic过期信息表';
+
+--
+-- Table structure for table `topic_metrics`
+--
+
+-- DROP TABLE IF EXISTS `topic_metrics`;
+CREATE TABLE `topic_metrics` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增id',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '-1' COMMENT '集群id',
+  `topic_name` varchar(192) NOT NULL DEFAULT '' COMMENT 'topic名称',
+  `metrics` text COMMENT '指标数据JSON',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  PRIMARY KEY (`id`),
+  KEY `idx_cluster_id_topic_name_gmt_create` (`cluster_id`,`topic_name`,`gmt_create`),
+  KEY `idx_gmt_create` (`gmt_create`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='topicmetrics表';
+
+--
+-- Table structure for table `topic_report`
+--
+
+-- DROP TABLE IF EXISTS `topic_report`;
+CREATE TABLE `topic_report` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '0' COMMENT '集群id',
+  `topic_name` varchar(192) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT 'topic名称',
+  `start_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '开始上报时间',
+  `end_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '结束上报时间',
+  `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `modify_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_cluster_id_topic_name` (`cluster_id`,`topic_name`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='开启jmx采集的topic';
+
+--
+-- Table structure for table `topic_request_time_metrics`
+--
+
+-- DROP TABLE IF EXISTS `topic_request_time_metrics`;
+CREATE TABLE `topic_request_time_metrics` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '-1' COMMENT '集群id',
+  `topic_name` varchar(192) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT 'topic名称',
+  `metrics` text COMMENT '指标',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  PRIMARY KEY (`id`),
+  KEY `idx_cluster_id_topic_name_gmt_create` (`cluster_id`,`topic_name`,`gmt_create`),
+  KEY `idx_gmt_create` (`gmt_create`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='topic请求耗时信息';
+
+--
+-- Table structure for table `topic_statistics`
+--
+
+-- DROP TABLE IF EXISTS `topic_statistics`;
+CREATE TABLE `topic_statistics` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增id',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '-1' COMMENT '集群id',
+  `topic_name` varchar(192) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT 'topic名称',
+  `offset_sum` bigint(20) NOT NULL DEFAULT '-1' COMMENT 'offset和',
+  `max_avg_bytes_in` double(53,2) NOT NULL DEFAULT '-1.00' COMMENT '峰值的均值流量',
+  `gmt_day` varchar(64) NOT NULL DEFAULT '' COMMENT '日期2020-03-30的形式',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `max_avg_messages_in` double(53,2) NOT NULL DEFAULT '-1.00' COMMENT '峰值的均值消息条数',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `uniq_cluster_id_topic_name_gmt_day` (`cluster_id`,`topic_name`,`gmt_day`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='topic统计信息表';
+
+--
+-- Table structure for table `topic_throttled_metrics`
+--
+
+-- DROP TABLE IF EXISTS `topic_throttled_metrics`;
+CREATE TABLE `topic_throttled_metrics` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+  `cluster_id` bigint(20) NOT NULL DEFAULT '-1' COMMENT '集群id',
+  `topic_name` varchar(192) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT 'topic name',
+  `app_id` varchar(64) NOT NULL DEFAULT '' COMMENT 'app',
+  `produce_throttled` tinyint(8) NOT NULL DEFAULT '0' COMMENT '是否是生产耗时',
+  `fetch_throttled` tinyint(8) NOT NULL DEFAULT '0' COMMENT '是否是消费耗时',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  PRIMARY KEY (`id`),
+  KEY `idx_cluster_id_topic_name_app_id` (`cluster_id`,`topic_name`,`app_id`),
+  KEY `idx_gmt_create` (`gmt_create`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='topic限流信息';
+
+--
+-- Table structure for table `work_order`
+--
+
+-- DROP TABLE IF EXISTS `work_order`;
+CREATE TABLE `work_order` (
+  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+  `type` int(16) NOT NULL DEFAULT '-1' COMMENT '工单类型',
+  `title` varchar(512) NOT NULL DEFAULT '' COMMENT '工单标题',
+  `applicant` varchar(64) NOT NULL DEFAULT '' COMMENT '申请人',
+  `description` text COMMENT '备注信息',
+  `approver` varchar(64) NOT NULL DEFAULT '' COMMENT '审批人',
+  `gmt_handle` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '审批时间',
+  `opinion` varchar(256) NOT NULL DEFAULT '' COMMENT '审批信息',
+  `extensions` text COMMENT '扩展信息',
+  `status` int(16) NOT NULL DEFAULT '0' COMMENT '工单状态, 0:待审批, 1:通过, 2:拒绝, 3:取消',
+  `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `gmt_modify` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='工单表';

docs/install_guide/install_guide_cn.md

@@ -0,0 +1,58 @@
+
+---
+
+![kafka-manager-logo](../assets/images/common/logo_name.png)
+
+**一站式`Apache Kafka`集群指标监控与运维管控平台**
+
+--- 
+
+# 安装手册
+
+
+## 环境依赖
+
+- `Maven 3.5+`(后端打包依赖)
+- `node 10+`(前端打包依赖)
+- `Java 8+`(运行环境需要)
+- `MySQL 5.7`(数据存储)
+
+---
+
+## 环境初始化
+
+执行[create_mysql_table.sql](create_mysql_table.sql)中的SQL命令，从而创建所需的MySQL库及表，默认创建的库名是`kafka_manager`。
+
+```
+# 示例：
+mysql -uXXXX -pXXX -h XXX.XXX.XXX.XXX -PXXXX < ./create_mysql_table.sql
+```
+
+---
+
+## 打包
+
+```bash
+
+# 一次性打包
+cd ..
+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.0.0-SNAPSHOT.jar --spring.config.location=./application.yml > /dev/null 2>&1 &
+```
+
+## 使用
+
+本地启动的话，访问`http://localhost:8080`，输入帐号及密码(默认`admin/admin`)进行登录。更多参考：[kafka-manager 用户使用手册](../user_guide/user_guide_cn.md)
+

docs/user_guide/add_cluster/add_cluster.md

@@ -0,0 +1,39 @@
+
+---
+
+![kafka-manager-logo](../../assets/images/common/logo_name.png)
+
+**一站式`Apache Kafka`集群指标监控与运维管控平台**
+
+--- 
+
+# 集群接入
+
+集群的接入总共需要三个步骤，分别是：
+1. 接入物理集群
+2. 创建Region
+3. 创建逻辑集群
+
+备注：接入集群需要2、3两步是因为普通用户的视角下，看到的都是逻辑集群，如果没有2、3两步，那么普通用户看不到任何信息。
+
+
+## 1、接入物理集群
+
+![op_add_cluster](assets/op_add_cluster.jpg)
+
+如上图所示，填写集群信息，然后点击确定，即可完成集群的接入。因为考虑到分布式部署，添加集群之后，需要稍等**`1分钟`**才可以在界面上看到集群的详细信息。
+
+## 2、创建Region
+
+![op_add_region](assets/op_add_region.jpg)
+
+如上图所示，填写Region信息，然后点击确定，即可完成Region的创建。
+
+备注：Region即为Broker的集合，可以按照业务需要，将Broker归类，从而创建相应的Region。
+
+## 3、创建逻辑集群
+
+![op_add_logical_cluster](assets/op_add_logical_cluster.jpg)
+
+
+如上图所示，填写逻辑集群信息，然后点击确定，即可完成逻辑集群的创建。