FlinkCDC

通过 FlinkCDC 实现 MySQL 数据库、表的实时变化监控,这里只把变化打印了

标签:java  linux  mysql  mysql  数据库  java  FlinkCDC  flink  

CDCCDC 是 Change Data Capture(变更数据获取)的简称。核心思想是,监测并捕获数据库的变动(包括数据或数据表的插入、更新以及删除等),将这些变更按发生的顺序完整记录下来,写入到消息中间件中以供其他服务进行订阅及消费。CDC 的种类CDC 主要分为基于查询和基于 Binlog 两种方式,我们主要了解一下这两种之间的区别:基于查询的 CDC

标签:数据采集  业务  数据  FlinkCDC  

1