需要引入 Flink CDC 的 jar 包,可以在 Maven 仓库中搜索 flink-connector-debezium 或 flink-connector-mysql-cdc。 在Flink CDC中,如果找不到某个包,需要引入相应的jar文件,以下是一些常见的Flink CDC相关包……