当前位置：网站首页>谁能解答？从mysql的binlog读取数据到kafka，但是数据类型有Insert,updata,

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

2022-08-04 17:48:00 【阿里云问答】

谁能解答？从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社区）

原网站

版权声明
本文为[阿里云问答]所创，转载请带上原文链接，感谢
https://developer.aliyun.com/ask/446968

边栏推荐

猜你喜欢

随机推荐