CDC(ChangeDataCapture)是一种用于捕捉数据库变更数据的技术,Flink从1.11版本开始原生支持CDC数据(changelog)的处理,目前已经是非常成熟的变更数据处理方案。
FlinkCDCConnectors是Flink的一组Source连接器,是FlinkCDC的核心组件,这些连接器负责从MySQL、PostgreSQL、Oracle、MongoDB等数据库读取存量历史数据和增量变更数据。FlinkCDCConnectors是一个独立的开源项目,从去年7月份开源以来,社区保持了相当高速的发展,平均两个月一个版本,在开源社区的