Flink 中文社区 | 中文学习教程Flink 中文社区是 Apache Flink 唯一授权的学习网站https://flink-learning.org.cn/article/detail/3ebe9f20774991c4d5eeb75a141d9e1e问题及测试集锦
1、flink cdc 的 api兼容的ddl的结构变更吗？
2、cdc 比如增量消费 然后 kill任务 再恢复？
3、mysql cdc 设置了检查点，sink到kafka，重启作业，为啥全量的数据还是会重新发送到kafka
4、CDC 到 KAFKA 时无法按照主键进行自动分区分发、无法指定分区键分发数据。到 KAFKA 的数据格式指定（JSON，AVRO JSON等）。
5、chanage-json format
测试3：chanage-json format 测试。
订单：
StreamTableEnvironment tableEnv = S
