背景：我想试用 flink sql 的 deduplicate 处理一个带*主键*的流，我发现 1. 如果我使用 mysql-cdc 获得一个流，它会报错 Deduplicate doesn't support consuming update and delete changes.... 2. 如果我使用 kafka json 获得一个流，虽然 deduplicate 不报错，但是不能设置主键，报错 The Kafka table '...' with 'json' format doesn't support defining PRIMARY KEY constraint on the table 3. 一个简单的满足上面要求的流是带主键的 datagen，它有主键，而且可以被 deduplicate 处理，但是太不可控。
请问还有别的连接器或格式支持吗，从文档中似乎不能很快地获得这一点。 -- Sent from: http://apache-flink.147419.n8.nabble.com/
