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

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

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

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

Flink CDC有没有遇到pg同步时间timestamp(6)类型会添加8小时的?

Flink CDC有没有遇到pg同步时间timestamp(6)类型会添加8小时的?

高性能

Flink CDC 实现企业级实时数据同步

传统的数据集成通常由全量和增量同步两套系统构成,在全量同步完成后,还需要进一步将增量表和全量表进行合并操作,这种架构的组件构成较为复杂,系统维护困难。本方案提供 Flink CDC 技术实现了统一的增量和全量数据的实时集成。
技术解决方案背景图
文章 2023-10-25 来自:开发者社区

Flink CDC的工作原理是通过监听数据库的binlog来实现实时数据同步的

Flink CDC的工作原理是通过监听数据库的binlog来实现实时数据同步的。一般来说,如果数据库的binlog输出速度正常,Flink CDC应该能够实时接收到所有的数据变更。 然而,如果你在两个小时内只收到了一条UPDATE操作,可能有以下几种原因: 数据库的binlog输出速度慢:这可能是由于数据库的负载...

文章 2023-10-25 来自:开发者社区

对于Flink CDC,当源表的数据被删除后,可以通过以下方法在结果表中同步删除

对于Flink CDC,当源表的数据被删除后,可以通过以下方法在结果表中同步删除: 使用DELETE语句:在Flink SQL中,可以直接使用DELETE语句从结果表中删除数据。例如: DELETE FROM result_table WHERE id IN (SELECT id FROM source_tabl...

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

请教一下Flink CDC,我现在CDC 同步Mysql到OSS,如何来控制Sink端的文件大小呢?

请教一下Flink CDC,我现在CDC 同步Mysql 到OSS,想问下如何来控制Sink端的文件大小呢,比如 source端4个并发,落成4个文件,那么到达多大的文件size,会rollup到新的文件呢?

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

请问Flink CDC sqlserver cdc 可以全量同步吗?

请问Flink CDC sqlserver cdc 可以全量同步吗?

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

Flink tidb cdc能否支持增量同步?

Flink tidb cdc能否支持增量同步?

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

Flink CDC有没有针对达梦数据库的扩展插件或者连接器,做实时数据同步?

Flink CDC有没有针对达梦数据库的扩展插件或者连接器,做实时数据同步?

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

Flink CDC问下PG 可以支持从slave同步数据了吗 ?

Flink CDC问下PG 可以支持从slave同步数据了吗 ?

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

Flink CDC1.13.6 cdc 2.3 同步MySQL的数据报的这个错误是什么问题?

Flink CDC1.13.6 cdc 2.3 同步MySQL的数据报的这个错误是什么问题?

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

产品推荐

阿里云实时计算Flink

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

+关注