有些数据是存储在业务库中的,比如MySQL,在建设基于Flink的实时数仓时,我们应该如何使用Flink实时对接业务库新增以及修改的数据?
提示:
1) 基于Flink建设的实时数仓的架构
2) 如何实时采集到的业务库比如MySQL数据库中新增和变化的数据
3) Flink对接Kafka数据如何保证精准一次消费语义
4) Flink中的两阶段提交是什么意思
有些数据是存储在业务库中的,比如MySQL,在建设基于Flink的实时数仓时,我们应该如何使用Flink实时对接业务库新增以及修改的数据?
提示:
1) 基于Flink建设的实时数仓的架构
2) 如何实时采集到的业务库比如MySQL数据库中新增和变化的数据
3) Flink对接Kafka数据如何保证精准一次消费语义
4) Flink中的两阶段提交是什么意思
数据加载中...