# flink-admin

**Repository Path**: csdn_bajia/flink-admin

## Basic Information

- **Project Name**: flink-admin
- **Description**: 基于Flink Rest API 二开的Web 控制台，支持作业管理、一键Savepoint及恢复，可视化实时数据同步功能（Binlog），多集群管理，开箱即用！！！
- **Primary Language**: Java
- **License**: MulanPSL-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 152
- **Created**: 2024-03-10
- **Last Updated**: 2024-03-10

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# flink-admin

#### 介绍
基于 flink rest api 的 flink web admin,  
支持任务持久化管理，JOB编辑、提交、启动、停止。  
支持多集群发布任务，任务根据场景选择不同的集群。  
支持一键Savepoint及指定Savepoint恢复任务。   
支持数据源管理，加密保存数据源配置信息。   
支持一键同步表结构。   
支持可视化配置单表，多表，全量及增量数据库同步任务（FlinkCDC实现）。  
支持 mysql to mysql,es.

#### 技术栈 
Springboot2.3.9 + FreeMarker+ flink1.13.3 + flinkCDC2.1.0

#### 架构图
![输入图片说明](imags/flink-admin%E7%B3%BB%E7%BB%9F%E6%A8%A1%E5%9D%97%E5%9B%BE.png)

#### 安装教程

##### 创建数据库
```
CREATE DATABASE IF NOT EXISTS flink-admin DEFAULT CHARSET utf8mb4;
SOURCE flink-admin.sql
```

##### 项目启动
```
git clone https://gitee.com/chongho/flink-admin.git
# mvn install
# java -jar flink-web-console.jar
```

#### 使用说明
http://localhost:8086/   
admin/123456  


#### 功能截图
上传资源包
![输入图片说明](imags/jar-list.png)    
作业列表 
![输入图片说明](imags/task-list.png)
新增作业 
![输入图片说明](imags/edit-task.png)
数据同步作业 
![输入图片说明](imags/sync-list.png)
新增数据同步作业
![输入图片说明](imags/edit-sync.png)

修改作业模板
1. 上传flink-cdc-job.jar 到flink集群.  
2. 修改对应的 jarId.   
![template.jpg](imags/template.jpg) 


#### 参与贡献

1.  Fork 本仓库
2.  新建 Feat_xxx 分支
3.  提交代码
4.  新建 Pull Request

#### 联系我们
![技术交流群](imags/%E4%B8%AD%E5%92%8C%E5%BC%80%E6%BA%90%E4%BA%A4%E6%B5%81%E7%BE%A4.jpg)

#### 特别说明
Copyright © 2022 中和农信