Apache paimon-CDC

 CDC集成

paimon支持五种方式通过模式转化数据提取到paimon表中。添加的列会实时同步到Paimon表中

• MySQL同步表：将MySQL中的一张或多张表同步到一张Paimon表中。
• MySQL同步数据库：将MySQL的整个数据库同步到一个Paimon数据库中。
• API同步表：将您的自定义DataStream输入同步到一张Paimon表中。
• Kafka同步表：将一个Kafka topic的表同步到一张Paimon表中。
• Kafka同步数据库：将一个包含多表的Kafka主题或多个各包含一表的主题同步到一个Paimon数据库中。

1、Mysql同步

准备：必须添加FlinkCDC连接器

cp flink-sql-connector-mysql-cdc-3.0.1.jar /opt/module/flink-1.18.0/lib,重启yarn-session集群和sql-client。重启yarn-session集群和sql-client。

1.1同步表

1）语法说明

<