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

大家有没有FLink CDC MySQL自定义sink 成json 数据输出出去的资料吗? 或者si

大家有没有FLink CDC MySQL自定义sink 成json 数据输出出去的资料吗? 或者sink到Redis?

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

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

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

高性能

基于 Flink CDC 打造企业级实时数据同步方案

传统的数据集成通常由全量和增量同步两套系统构成,在全量同步完成后,还需要进一步将增量表和全量表进行合并操作,这种架构的组件构成较为复杂,系统维护困难。本方案提供 Flink CDC 技术实现了统一的增量和全量数据的实时集成。
技术解决方案背景图
问答 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中执行了哪些sql吗?

Flink CDC能还原MySQL中执行了哪些sql吗?

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

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

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

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

大佬,Flink CDC 从mysql数据sink到es,可以支持es的人geopoint类型吗

大佬,Flink CDC 从mysql数据sink到es,可以支持es的人geopoint类型吗

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

Flink CDC自定义反序列化 然后同步mysql8.0 读取binlog时报空指针 有遇到过

Flink CDC自定义反序列化 然后同步mysql8.0 读取binlog时报空指针 有遇到过的大佬么?

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

flink cdc读取到mysql的时间带有T和Z,有什么好的办法可以去除掉这个T和Z呢,我直接就想

flink cdc读取到mysql的时间带有T和Z,有什么好的办法可以去除掉这个T和Z呢,我直接就想转换成 年月日 时分秒的格式来使用 ?

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

有人遇到过 上游使用flink cdc 映射MySQL表;然后写入到下游的JDBC映射表;上游MyS

有人遇到过 上游使用flink cdc 映射MySQL表;然后写入到下游的JDBC映射表;上游MySQL更新数据;下游的MySQL的数据总条数总是从减少然后又增加到和上游数据总数一样;数据积压也基本上没有;checkpoint也是设置的毫秒级;上游仅仅是更新数据并没有删除数据;

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注