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