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࿰