我们用 Flink CDC 完成 CDC 数据入湖任务:借助 Flink CDC 从源头数据库接入数据并写入到 Kafka 中,然后再使用 Flink 将数据写入到 Hudi 表中,所以这是一个完整的端到端的解决方案。上一篇文章我们省略了搭建 Kafka Connect + Debezium MySQL Connector 采集 CDC 数据的环节,因为这部分操作很复杂,Flink CDC 在应用和架构上确实比 Kafka Connect + Debezium MySQL Connector 的组合简单得多