flink cdc

CDC是 Change Data Capture(变更数据获取 )的简称。 核心思想是，监测并捕获数据库的变动（包括数据或数据表的插入 、 更新 以及 删除等），将这些变更按发生的顺序完整记录下来，写入到消息中间件中以供其他服务进行订阅及消费。

Flink社区开发了 flink-cdc-connectors 组件，这是一个可以直接从 MySQL、 PostgreSQL 等数据库直接 读取全量数据 和 增量变更数据 的 source 组件。

说白了就是连接数据库，然后实时监控变化