阿里云文档 2024-09-30

将PolarDB PostgreSQL版(兼容Oracle)同步到Kafka

本文介绍如何使用数据传输服务DTS(Data Transmission Service),将PolarDB PostgreSQL版(兼容Oracle)集群的数据同步至阿里云消息队列Kafka版。

阿里云文档 2024-06-27

如何创建Kafka实时ETL同步至Hologres任务_大数据开发治理平台 DataWorks(DataWorks)

实时ETL同步方案根据来源Kafka指定Topic的内容结构对目的Hologres表结构做初始化,然后将Kafka指定Topic的存量数据同步至Hologres,同时也持续将增量数据实时同步至Hologres。本文为您介绍如何创建Kafka实时ETL同步至Hologres任务。

问答 2024-04-08 来自:开发者社区

Flink CDC里整库同步支持mysql->kafka吗?这个有示例吗?

Flink CDC里整库同步支持mysql->kafka吗?这个有示例吗? flink cdc 的schema evolution只能支持整库同步的场景吗?

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

请教下 flink-cdc同步到kafka怎么才能拿到完整热搜canal-json格式?

$stringUtil.substring( $!{XssContent1.description},200)...

问答 2024-03-20 来自:开发者社区

我想请教一个问题,通过flink同步kafka数据进到doris,Flink这个该怎么处理?

我想请教一个问题,通过flink同步kafka数据进到doris,decimal数值类型的在kafka是正常显示数值,但是同步到doris表之后数据就变成了整数,Flink这个该怎么处理?

问答 2024-03-11 来自:开发者社区

Flink CDC 里做全库同步的时候mysql到kafka、报这个错误是少什么东西了?

Flink CDC 里做全库同步的时候mysql到kafka、报这个错误是少什么东西了?

问答 2024-03-11 来自:开发者社区

dataworks可以实现30秒左右的调度频率同步kafka数据到mc吗?

dataworks可以实现30秒左右的调度频率同步kafka数据到mc吗?

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

Flink CDC里mysql-cdc同步到kafka中,对同一条数据多次操作,怎么区分先后?

Flink CDC里mysql-cdc同步到kafka中,对同一条数据多次操作,op_ts字段可能会一样,如何区分先后顺序呢?同一条数据在短时间内有i、d、u操作,操作时间读取过来也是同一个,这咋区分哪个前哪个后呢?

问答 2023-12-19 来自:开发者社区

Flink CDC使用datax或者其他全量工具同步到kafka; 是这个意思吧?

Flink CDC使用datax或者其他全量工具同步到kafka;第二步等kafka消费端完成了消费;第三步消费完后启动flink cdc增量方式,把同步全量开始的时间转换时间戳作为flink增量的时间戳开始同步更新;全量(datax)和增量(flink cdc)结合,是这个意思吧?

问答 2023-12-19 来自:开发者社区

Flink CDC1.16版本,从oracle同步到kafka,请问你们怎么解决的?

$stringUtil.substring( $!{XssContent1.description},200)...

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

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注