阿里云文档 2025-06-05

PolarDB PostgreSQL版连接器

本文为您介绍如何使用PolarDB PostgreSQL版(Oracle语法兼容1.0)连接器。

问答 2025-01-08 来自:开发者社区

flink cdc实时同步oracle数据库到kafka报错

flink cdc实时同步oracle数据库到kafka,我自己新建的测试表可以正常同步存量和增量数据,用另一张千万级别数据的表直接启动报错Caused by: java.io.IOException: io.debezium.DebeziumException: The db history topic or its content is fully or partially missing.....

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

flink cdc里 Oracle to kafka sql的提交方式 咋还有序列化错误?

flink cdc里 Oracle to kafka sql的提交方式 咋还有序列化错误?

问答 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-06-04 来自:开发者社区

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

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

问答 2022-10-24 来自:开发者社区

Flink-CDC 采集 Oracle 数据发送到下游 kafka 或其他存储端时, 数据不断膨胀

Flink-CDC 采集 Oracle 数据发送到下游 kafka 或其他存储端时, 数据不断膨胀的问题 (例如: Oracle源库9千万, kafka端2~30亿), 如果不手动关闭采集程序数据就会一直进来

问答 2022-08-24 来自:开发者社区

求助:flink cdc 从oracle或者mysql 同步到kafka,但是最近一个update操

求助:flink cdc 从oracle或者mysql 同步到kafka,但是最近一个update操作,变成了两条记录,一条delete,然后一条insert,之前是一条数据,before有之前数据,after是修改后的数据,然后记录中操作类型是op:u,现在就变成op:d+op:c了,怎么办?

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

产品推荐

阿里云实时计算Flink

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

+关注
AI助理

你好,我是AI助理

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

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问