Flink CDC MySQL 同步数据到 Kafka实践中可能遇到的问题
一、问题场景
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.ValidationException: The primary key is necessary when enable 'Key: 'scan.incremental.snapshot.enabled' , default: true (fallback keys: [])' to 'true'
当你遇到org.apache.flink.table.api.ValidationException错误，提示需要主键以启用增量快照功能（scan.incremental.snapshot.enabled
