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

用flink cdc同步rds上的mysql数据到kafka里,请问这是什么情况?

用flink cdc同步rds上的mysql数据到kafka里,但是每次update的时候会被拆成一个create和一个delete事件。请问这是什么情况,我如果需要update时输出update事件该怎么处理?

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

Flink CDC中mysql 同步kafka 给报了个这错?

Flink CDC中mysql 同步kafka 给报了个这错, sink是侧输出流 表也不大就400万,列有200列,初始化的时候报的 有遇到过的吗?

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

有没有Hudi on Flink动态同步元数据变化的方法,即读取的kafka数据新增了字段?

有没有Hudi on Flink动态同步元数据变化的方法,即读取的kafka数据新增了字段,需要hudi表也动态新增该字段(这个变化发生在不同天,同一天数据元数据是一致的)。

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

Flink CDC为什么我同步mongodb到kafka完成后点击savepoint停止?

Flink CDC为什么我同步mongodb到kafka完成后点击savepoint停止后,savepoint那么大?mysql到kafka就不会有这个问题

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

flink cdc sql方式将mysql同步到kafka时报发下错误,有遇到的吗?

flink cdc sql方式将mysql同步到kafka时报发下错误,kafka是集群模式,有遇到的吗?

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

OceanBase数据库 OMS同步kafka报错这个,该如何解决?

OceanBase数据库 OMS同步kafka报错这个,该如何解决?https://ask.oceanbase.com/t/topic/35604849

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

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

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

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

pg cdc同步到 kafka,发现同步的同一批数据,大部分数据多了8小时,这种情况大家有遇见过么?

pg cdc 同步到 kafka,发现同步的同一批数据,大部分数据多了8小时,少部分数据是正常的,这种情况大家有遇见过么?

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

Flink CDC使用oraclecdc同步到kafka在快照阶段就发生了oom 有什么办法解决嘛?

Flink CDC使用oraclecdc同步到kafka 在快照阶段就发生了oom 有什么办法解决嘛 taskmanager内存给的是18g?这个是sql的参数

问答 2023-08-28 来自:开发者社区

OceanBase数据库OMS同步任务推送到kafka怎么查看数据格式呢?

OceanBase数据库OMS同步任务推送到kafka怎么查看数据格式呢?

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

产品推荐

消息队列

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

+关注