flinkcdc 需要引入:

        source端:

flink-cdc-pipeline-connector-mysql-xxx.jar、mysql-connector-java-xxx.jar、

        sink端:

flink-cdc-pipeline-connector-paimon-xxx.jar

flinkcdc官方提供connect包下载地址,pipeline模式提交作业和source代码模式提交作业需要的jar包:

Releases · apache/flink-cdc · GitHub

Logo

一站式 AI 云服务平台

更多推荐