生产级 Flink CDC 应用开发与部署：MySQL 到 Kafka 同步示例

生产级 Flink CDC 应用开发与部署：MySQL 到 Kafka 同步示例

为了帮助你更好地理解如何将 Flink 作业部署为独立服务，下面我将提供一个完整的工程代码示例。这个例子基于之前的 MySQL 到 Kafka 的数据同步需求，但这次我们将 Flink 作业作为一个独立的服务进行打包和部署。

工程结构

flink-cdc-job/
├── pom.xml
└── src/└── main/├── java/│   └── com.example.flinkcdc│       ├── CdcToKafkaJob.java│       ├── config/│       │   └── AppConfig.java│       └── model/│           └── User.java└── resources/└── application.properties

Maven 配置 (pom.xml)