问答 2024-02-01 来自:开发者社区

Flink CDC 可以完全替代,阿里云dts、canal、maxwell等软件,作为数据同步工具?

Flink CDC中,我想通过一次数据同步操作,允许不同的下游服务进行消费,感觉用flink cdc就可以实现所有的功能,所以在想有没有必要单独再搞一个dts做数据同步,如:MySQL—>MySQL,可以实现吗?

文章 2022-11-05 来自:开发者社区

使用Flink 读取kafka Catalog 源表数据展开json写入下游hologres表示例操作

本文主要介绍如何使用Flink  读取kafka Catalog 源表数据写入下游hologres存储,并演示'json.infer-schema.flatten-nested-columns.enable参数,递归的展开JSON中的嵌套列的效果。一 准备工作本文测试使用 阿里云消息队列Kafka版进行演示,依据Flink集群的网络环境(VPC),构建相关上下游数据源,并做好白明单访问....

使用Flink 读取kafka Catalog 源表数据展开json写入下游hologres表示例操作

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注