Flink CDC中mysql到mysql如何实现？

Flink实现MySQL到MySQL的CDC数据同步,可以采用以下方式:

使用Flink CDC监控MySQL源库变更日志,同时将数据写出至Kafka/Kinesis等消息中间件。
然后使用Flink SQL从消息队列消费数据,写入目标MySQL数据库。

使用Debezium监控MySQL源库变更日志,同步生成SQL DML语句,写入Kafka。
然后使用Flink SQL消费Kafka,执行DML操作写入目标MySQL。

使用Debezium监控源库变更日志,使用JDBC Sink将DML statements直接写入目标MySQL数据库。

如果源目标数据库相同,可以利用MySQL binlog feature实现,使用FlinkSQL跨库查询同步。

选择方式需要考虑:

两数据库是否相同
是否需要中间缓冲
限流控制需求
并发性能
一般采用第1、2种方式间接实现优先,避免直接操作MySQL可能产生的并发问题。

cdc-》jdbc，有jdbc的 connector你看看flink 官网里有的，cdc 只是source 。此回答整理至钉群“Flink CDC 社区”。