可以参考 https://github.com/leonardBang/flink-sql-etl/tree/master/flink-demo/flink-temporal-join-demo <https://github.com/leonardBang/flink-sql-etl/tree/master/flink-demo/flink-temporal-join-demo>
> 2021年3月18日 下午4:41，guoyb <[email protected]> 写道： > > mysql cdc表 和kafka表关联，应该怎么写，有对应示例吗？
