谁能解答？从mysql的binlog读取数据到kafka，但是数据类型有Insert,updata,

谁能解答？从mysql的binlog读取数据到kafka，但是数据类型有Insert,updata,delete ,如何保证通过flink流式计算kafka出来的结果跟在mysql计算出来的一样呢？就比如，mysql是select id,sum(money) money from tb1 group by id; 那么此时flink sql应该怎么写呢？

---

采纳答案1：

这个https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/table/formats/canal/可参考下（此答案整理自【③群】Apache Flink China社区）

---