正文摘要:

本帖最后由 levycui 于 2020-11-4 22:13 编辑 问题导读： 1、CDC是什么？ 2、Flink提供的 table format如何实现？ 3、如何实现mysql-cdc的操作？ 4、如何实现changelog-json的操作？ Flink1.11引入了CDC ...