当前位置：网站首页>谁能解答？从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社区）
边栏推荐
- 集群监控——Zabbix使用
- How to make JS code unbreakable
- js函数传参是按值传递还是按引用传递？
- 并发编程原理学习-reentrantlock源码分析
- 88. (the home of cesium) cesium polymerization figure
- 如何模拟后台API调用场景，很细！
- Understand Chisel language. 32. Chisel advanced hardware generator (1) - parameterization in Chisel
- 关于大学生内卷的文献综述
- 静态iP与权限更改[通俗易懂]
- LVS+Keepalived群集
猜你喜欢
![[Web Automation Test] Quick Start with Playwright, 5 minutes to get started](/img/68/36dd8ef4a4073f03d5e5dad91be20d.png)
随机推荐
php如何查询字符串以什么开头
"Involution" Index Analysis Based on AHP
Thrift IDL Sample File
怎么面试程序员的？傲慢与无礼，就数他牛逼
About the two architectures of ETL (ETL architecture and ELT architecture)
darknet源码阅读笔记-02-list.h和lish.c
树莓派利用autofs自动挂载/卸载外部硬盘
DSPE-PEG-DBCO,DBCO-PEG-DSPE,磷脂-聚乙二醇-二苯并环辛炔科研实验用
并发编程原理学习-reentrantlock源码分析
斯坦福：未来的RGB LED可以贴在你的皮肤上
基于大学生内卷行为的调查研究
公司自用的国产API管理神器
JS兼容问题总结
小程序笔记3
How to make JS code unbreakable
Interval greedy (interval merge)
【web自动化测试】Playwright快速入门，5分钟上手
Understand Chisel language. 32. Chisel advanced hardware generator (1) - parameterization in Chisel
荣耀互联对外开放，赋能智能硬件合作伙伴，促进全场景生态产品融合
租房小程序登顶码云热门