Spring Boot + Flink + FlinkCDC 实现 MySQL 同步到 MySQL

Spring Boot + Flink + FlinkCDC 实现 MySQL 同步到 MySQL 工程代码

在数据处理领域，实时数据同步是关键需求之一。下面我将为大家介绍如何利用 Spring Boot 2.3.12.RELEASE、Flink 1.15.4 和 FlinkCDC 2.4.0 实现 MySQL 同步到 MySQL 的完整工程代码实现，助力大家快速上手。

一、项目搭建

1. 创建 Spring Boot 项目

使用 Spring Initializr 创建项目，选择 Spring Boot 版本为 2.3.12.RELEASE，勾选所需依赖，如 Spring Web 等，完成项目创建。

2. 添加 Maven 依赖

在 pom.xml 文件中添加以下关键依赖：

<properties>