CDC首先什么是CDC ？它是Change Data Capture的缩写,即变更数据捕捉的简称，使用CDC我们可以从数据库中获取已提交的更改并将这些更改发送到下游，供下游使用。这些变更可以包括INSERT,DELETE,UPDATE等操作。Flink SQL CDC 数据同步与原理解析CDC 全称是 Change Data Capture ，它是一个比较广义的概念，只要能捕获变更的数据，我们都可

flink实时消费kafka中oracle的DDL数据写入mysql前言：上篇文章：https://mp.csdn.net/mp_blog/creation/editor/118930336说到了kafka如何实时获取oralce的DDL，下面来说下flink如何消费kafka数据并sink到任意数据库。参考文档：https://www.cnblogs.com/yaowentao/p/148400

前言：之前使用confluent已经出过文档，因为confluent插件比较老，小编只是演示用，而且confluent对应数据的更新删除不好识别，这次小编使用的是debezium搭配单机的kafka环境，演示以单机环境为主，但会说到集群。1.环境1.1、Kafka：kafka_2.13-2.8.01.2、数据库：/Oracle11G。（Oracle开启归档）1.3、计算引擎：Flink 1.13.