Flink-advanced Flink 实用示例代码。 环境 JDK 11 Flink 1.16.1 Flink-stream 模块 示例代码因 Flink-cdc 版本问题与 Flink 版本不兼容，需自行编译 cdc 适配 Flink 版本。 Flink-cdc 自定义序列化器 Flink-cdc changelog 按规则分流写入不同表