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

请问,flink cdc 全量同步 不加锁,如果要同步binlog之前的数据的话,是通过select

请问,flink cdc 全量同步 不加锁,如果要同步binlog之前的数据的话,是通过select 查表获取全量数据的吗?另外: 在同步全量数据的同时,如果数据库还有更新,那么是如何解决的?

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

大佬 Flink CDC 整库同步只能实现相同表结构的是吧?

大佬 Flink CDC 整库同步只能实现相同表结构的是吧?

高性能

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

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

请教各位一个问题,我使用Flink CDC同步MYSQL数据到Elasticsearch,当我停掉F

请教各位一个问题,我使用Flink CDC同步MYSQL数据到Elasticsearch,当我停掉Flink后,在MYSQL中删除数据,再启动Flink CDC job,这时候Elasticsearch中存在脏数据,没有删除掉MYSQL中已经删除了的数据,这种情况有遇到的吗?

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

请教一下大佬们,我用FLink CDC 同步MySQL数据 ,然后进行聚合通过自定义一个MQTT s

请教一下大佬们,我用FLink CDC 同步MySQL数据 ,然后进行聚合通过自定义一个MQTT sink推出去?结果自定义的sink flink死活加载不出了 找不到 但是我一直感觉自己代码没有问题,有经验的大佬帮忙给点意见

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

请教下,使用flink cdc同步数据到hudi ,如果mysql 字段有新增,怎么弄

请教下,使用flink cdc同步数据到hudi ,如果mysql 字段有新增,怎么弄

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

Flink CDC全量阶段的无锁同步是仅支持Mysql还是其他库的connector都支持了?

Flink CDC全量阶段的无锁同步是仅支持Mysql还是其他库的connector都支持了?

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

各位大佬, flink cdc从kafka同步数据到 hudi , 写入效率很低,目前只能达到每分钟

各位大佬, flink cdc从kafka同步数据到 hudi , 写入效率很低,目前只能达到每分钟10W左右 ,使用的是MOR。 有没有大佬指导一下

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

有没有遇到 Flink CDC离线数据能同步 但是实时数据同步不了的?

有没有遇到 Flink CDC离线数据能同步 但是实时数据同步不了的?

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

请教 一个问题,flink cdc 支持一条语句 整库同步吗?是需要自己扩展开发吗

请教 一个问题,flink cdc 支持一条语句 整库同步吗?是需要自己扩展开发吗

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

flink 1.15.3 mysql cdc 2.3.0 同步到kafka 出现了这个异常信息Fa

flink 1.15.3 mysql cdc 2.3.0 同步到kafka 出现了这个异常信息Failed to deserialize data of EventHeaderV4{timestamp=1681910072000, eventType=WRITE_ROWS, serverId=2578535688, headerLength=19, dataLength=8182, nextP.....

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

产品推荐

阿里云实时计算Flink

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

+关注