当前位置:网站首页>谁能解答?从mysql的binlog读取数据到kafka,但是数据类型有Insert,updata,
谁能解答?从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应该怎么写呢?
边栏推荐
- Has legal counsel become a tasteless product of law firms?
- 欧拉函数(用欧拉筛法求欧拉函数)
- 2022-08-09 顾宇佳 学习笔记
- 通过Xshell连接Vagrant创建的虚拟机
- 借问变量何处存,牧童笑称用指针,Go lang1.18入门精炼教程,由白丁入鸿儒,go lang类型指针(Pointer)的使用EP05
- For the first time, I suspect that there is a bug in selenium4 because the iframe element is not found?
- Openlayers 聚合图、权重聚合图以及聚合图点击事件
- Continuous Integration/Continuous Deployment (2) Jenkins & SonarQube
- 刷题错题录2-向上取整、三角形条件、字符串拼接匹配、三数排序思路
- Nuget找不到包的问题处理
猜你喜欢
shell之sed
Analysis of the Status Quo of Enterprise Server Host Reinforcement
Features of LoRa Chips
ASP.NET Core 6框架揭秘实例演示[32]:错误页面的集中呈现方式
如何通过开源数据库管理工具 DBeaver 连接 TDengine
Mysql JSON对象和JSON数组查询
VoLTE基础自学系列 | 3GPP规范解读之Rx接口(上集)
excel 透视表 值显示内容 不显示计数
Redis 只会用缓存?20种妙用让同事直呼牛X(荣耀典藏版)
框架外的PHP读取.env文件(php5.6、7.3可用版)
随机推荐
Analysis of the Status Quo of Enterprise Server Host Reinforcement
【云原生】云原生在网络安全领域的应用
[wxGlade learning] wxGlade environment configuration
mysql添加用户以及设置权限
go-grpc TSL authentication solution transport: authentication handshake failed: x509 certificate relies on ... ...
Filesystem Hierarchy Standard
抽象类和接口
数据库无法启动,报无法分配内存,怎么处理
YTU 2297: KMP pattern matching three (string)
gRPC系列(二) 如何用Protobuf组织内容
flex布局回顾
基于 VIVADO 的 AM 调制解调(2)工程实现
《价值》读书与投资
Alibaba Sentinel - Slot chain解析
企业服务器主机加固现状分析
AcWing 272. 最长公共上升子序列
Machine Learning Summary (2)
持续集成/持续部署(2)Jenkins & SonarQube
流式结构化数据计算语言的进化与新选择
Design of Cluster Gateway in Game Server