Flink CDC 连接器 2.2 版本适配 Flink 1.14.2

该项目对 Flink CDC Connectors 2.2 版本进行了源码级别的修改,使其能够兼容 Flink 1.14.2 版本,并针对 MySQL 数据库进行了优化,以提升数据采集的性能和稳定性。

优化内容包括:

* 修复了 Flink 1.14.2 版本兼容性问题

* 提升了 MySQL CDC 数据采集的效率

* 增强了连接器的稳定性

使用方式:

1. 下载修改后的源码

2. 编译打包

3. 将生成的 JAR 包添加到 Flink 项目中

4. 配置并使用 Flink MySQL CDC 连接器