当前位置：网站首页>谁能解答？从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应该怎么写呢？
边栏推荐
- ImportError: /usr/local/cuda-11.2/lib64/libcublas.so.10: version `libcublas.so.10‘ not found
- What should I do if the mysql data query causes the cup to be full because the query time span is too large
- 小目标检测3_注意力机制_Self-Attention
- 盘点四个入门级SSL证书
- 基于 VIVADO 的 AM 调制解调（2）工程实现
- Rust从入门到精通06-函数
- 通过Xshell连接Vagrant创建的虚拟机
- js将table生成excel文件并去除表格中的多余tr（js去除表格中空的tr标签）
- 当你领导问你“还有其他的么”
- tensorflow 基础操作1(tensor 基本属性 ， 维度变换，数学运算)
猜你喜欢
随机推荐
当你领导问你“还有其他的么”
One network cable to transfer files between two computers
表达式必须具有与对应表达式相同的数据类型
JUC Concurrent Programming
go-grpc TSL authentication solution transport: authentication handshake failed: x509 certificate relies on ... ...
关于架构的认知
企业服务器主机加固现状分析
轻量级网络(一)：MobileNet V1，V2, V3系列
Kotlin算法入门计算水仙花数
Analysis of the Status Quo of Enterprise Server Host Reinforcement
如何通过开源数据库管理工具 DBeaver 连接 TDengine
Kotlin算法入门求回文数数算法优化二数字生成规则
gRPC系列(二) 如何用Protobuf组织内容
[wxGlade learning] wxGlade environment configuration
Filesystem Hierarchy Standard
《剑指offer》题解——week3（持续更新）
Openlayers Aggregate Graph, Weight Aggregate Graph, and Aggregate Graph Click Events
What should I do if the mysql data query causes the cup to be full because the query time span is too large
小目标检测3_注意力机制_Self-Attention
UNITY gameobject代码中setacvtive(false)与面板中直接去掉勾 效果不一样