阿里云文档 2025-01-21

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

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

阿里云文档 2025-01-21

将PolarDB PostgreSQL版(兼容Oracle)的数据迁移到Kafka

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

问答 2024-07-10 来自:开发者社区

flinkcdc同步oracle到kafka刚开始加了那两个参数可以秒级监控,有经验知道怎么排查吗?

flinkcdc同步oracle到kafka刚开始加了那两个参数可以秒级监控,现在过了几周数据延迟又到几十秒和分钟级了,有兄弟有经验知道怎么排查吗(测试环境)数据都是一条一条的造的?

问答 2024-07-10 来自:开发者社区

之前flink-cdc可以正常同步oracle的数据,发现kafka没有最新数据生产了怎么办?

之前flink-cdc可以正常同步oracle的数据,但是某次异常后,flink自动重启后就不能正常同步oracle的数据了,发现kafka没有最新数据生产了?任务的状态也是正常的,一值是running的

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

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

Flink CDC1.16版本,从oracle同步到kafka,kafka的配置信息如下:报这个错误:Caused by: org.apache.kafka.common.errors.InvalidProducerEpochException: Producer attempted to produce with an old epoch.请问你们怎么解决的?小数据量表就没有问题,大数据量表1....

问答 2023-11-06 来自:开发者社区

Flink CDC有使用ORACLE 分区表的CDC到Kafka 吗?

Flink CDC有使用ORACLE 分区表的CDC到Kafka 吗? 别的表正常,分区表总是报这个错误。String msg = "The db history topic or its content is fully or partially missing. Please check database history topic configuration and re-execute ....

问答 2023-10-23 来自:开发者社区

使用flinkcdc 2.2版本链接oracle19c 写入kafka2.12,已经配置?

使用flinkcdc 2.2版本链接oracle19c 写入kafka2.12,init初始化全量同步每秒可以写入2w,增量实时写入oracle表,然后查看flink webui界面平均速度也就3000/s,debezium.log.mining.strategy=online_catalog已经配置?我看这个一次采集的数据大概在4w左右,然后十几秒去采集一次,不能通过增加单次拉取数据或者减少采....

问答 2023-10-04 来自:开发者社区

flinkcdc oracle 的整库同步 需要先到kafka 么?

flinkcdc oracle 的整库同步 需要先到kafka 么?

问答 2023-06-11 来自:开发者社区

用flinkcdc-oracle2.2.1全量同步数据到kafka,开始很快,然后掉一大截?

用flinkcdc-oracle2.2.1全量同步数据到kafka,开始很快,然后掉一大截?

问答 2023-06-04 来自:开发者社区

有没有大佬 搞过 Flink CDC 整库同步 oracle 到 kafka , 合并的那种 ?

有没有大佬 搞过 Flink CDC 整库同步 oracle 到 kafka , 合并source 的那种 ?

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

相关镜像
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等