flink mysql cdc到kafka_停不下的脚步 思路: 1、创建flink mysql cdc表 2、将order join products的结果写入到kafka表中。 这样就相当于完成了,DWD中的事实表构建。写入到kafka中,等待消费构建DWS或者ADS。 主要参考https://ververica.github.io/flink-cdc-connectors/master/content/快速上... cdc表2将order irpas 7036 02-07