Hi, all 我们在使用Flink CDC同步多张表,然后合并slink到一张es表中。但表之间有数据流转关系,比如有table_1, table_2, table2, 一条数据A之前table_1,但后续可能更新到table_2。 想请教下,如果使用正则表达式匹配同步分表,是否可以保证数据有序无误呢? 也就是全部分表同时快照,且等待所有分表快照同步完后才开始处理binlog。 从文档[1]中看到对于单表这种模式是可以保证的,但不确定多表且有数据流转是否也一样。
[1] https://ververica.github.io/flink-cdc-connectors/master/content/connectors/mysql-cdc.html MySQL CDC Connector — Flink CDC documentation<https://ververica.github.io/flink-cdc-connectors/master/content/connectors/mysql-cdc.html> SQL Client JAR¶. Download link is available only for stable releases.. Download flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar and put it under <FLINK_HOME>/lib/.. Setup MySQL server¶. You have to define a MySQL user with appropriate permissions on all databases that the Debezium MySQL connector monitors. ververica.github.io