MySQL CDC #

Flink CDC2.0 #

参考: Flink CDC 2.0 数据处理流程全面解析

数据修正 #

com.ververica.cdc.connectors.mysql.table.MySqlTableSourceFactory#createDynamicTableSource
  com.ververica.cdc.connectors.mysql.table.MySqlTableSource#new

com.ververica.cdc.connectors.mysql.table.MySqlTableSource#getScanRuntimeProvider
  分布式读(是)
    com.ververica.cdc.connectors.mysql.source.MySqlParallelSource#new
  分布式读(否)
    com.ververica.cdc.debezium.DebeziumSourceFunction#new

MySqlSource 分析 #