当前位置：网站首页>谁能解答？从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应该怎么写呢？
边栏推荐
- jenkins 流水线脚本详细解析Pipeline
- idea 方法注释：自定义修改method的return和params，void不显示
- AUTOSAR从入门到精通番外篇（八）-C语言常用技巧50个
- 基础SQL——DDL
- Notable NFT development trends in 2022
- SDUT 2877:angry_birds_again_and_again
- 借问变量何处存,牧童笑称用指针,Go lang1.18入门精炼教程，由白丁入鸿儒，go lang类型指针(Pointer)的使用EP05
- Filesystem Hierarchy Standard
- [UEFI]EFI_DEVICE_PATH_PROTOCOL 结构体初始化的一个例子
- shell之sed
猜你喜欢
Inventorying Four Entry-Level SSL Certificates
C语言操作符详解
框架外的PHP读取.env文件（php5.6、7.3可用版）
One network cable to transfer files between two computers
几何EX3 功夫牛宣布停售，入门级纯电产品为何总成弃子
关于架构的认知
Detailed Explanation of the Level 5 Test Center of the Chinese Institute of Electronics (1)-string type string
Initial use of IDEA
dsu on tree（树上启发式合并）学习笔记
基于 VIVADO 的 AM 调制解调（1）方案设计
随机推荐
Nuget找不到包的问题处理
nodejs微服务中跨域，请求，接口，参数拦截等功能
IQUNIX A80 exploring TTC金粉 初体验
【系统梳理】当我们在说服务治理的时候，其实我们说的是什么？
如何通过 IDEA 数据库管理工具连接 TDengine？
分门别类输入输出,Go lang1.18入门精炼教程，由白丁入鸿儒，go lang基本数据类型和输入输出EP03
关于架构的认知
Machine Learning Summary (2)
仙人掌之歌——大规模高速扩张（1）
Mysql JSON对象和JSON数组查询
MySql事务
Go 语言的诞生
Filesystem Hierarchy Standard
程序员是一碗青春饭吗？
Alibaba Sentinel - Slot chain解析
ImportError: /usr/local/cuda-11.2/lib64/libcublas.so.10: version `libcublas.so.10‘ not found
@RequiredArgsConstructor注解
Swagger简单使用
pycharm中绘图，显示不了figure窗口的问题
小目标检测3_注意力机制_Self-Attention