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

2022-08-11 08:52:00 【阿里云问答】

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