flink-cdc
flink-cdc copied to clipboard
[WIP] [mysql] Support starting from specific timestamp in the new MySqlSource
Duplicated to #1157. Besides that, this code change filters the records by the timestamp instead of reading from the timestamp.
cc @leonardBang