问答 2023-01-29 来自:开发者社区

flink cdc同步,能不能不删除es的数据呢?

MySQL 业务表。要定期清理三个月前数据。但是es中要保留全量数据。flink cdc同步的话。能不能不删除es的数据呢?

问答 2023-01-29 来自:开发者社区

怎么使用flink sql,用cdc同步mysql中的json,然后写入es的动态字段啊?

怎么使用flink sql,用cdc同步mysql中的json,然后写入es的动态字段啊?

高性能

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

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

Flink CDC有大佬做oracle 到doris的多表同步吗?可以分享一下实践经验吗?

Flink CDC有大佬做oracle 到doris的多表同步吗?可以分享一下实践经验吗?

问答 2023-01-29 来自:开发者社区

Flink CDC今天发现线上同步pgsql, 还出现这个异常,为什么?

Flink CDC今天发现线上同步pgsql, 还出现这个异常,为什么?

问答 2023-01-15 来自:开发者社区

对于Flink CDC,大家的oracle 同步到doris参考啥进行的呢?

对于Flink CDC,大家的oracle 同步到doris参考啥进行的呢?

问答 2023-01-15 来自:开发者社区

flink mysql cdc 多表同步到hudi,要怎样动态创建hudi sink呢?

flink mysql cdc 多表同步到hudi,在hudi表schema不能明确知道的情况下,要怎样动态创建hudi sink呢?

问答 2023-01-15 来自:开发者社区

对于Flink CDC,同步oracle initial 方式,同步程序跑一会,就停下来了,为什么?

对于Flink CDC,同步oracle initial 方式,同步程序跑一会,就停下来了,这个有遇到过的吗, 同步了5w条就不同步了 2023-01-11 17:50:52.343 INFO 23902 --- [Unnamed (1/1)#0] io.debezium.embedded.EmbeddedEngine : Stopping the embedded engine 2...

问答 2023-01-15 来自:开发者社区

flink cdc同步,kafka必须设置成1个partition才能确保数据一致性吗?

flink cdc同步binglog到kafka,flink再消费kafka到目标库,kafka必须设置成1个partition才能确保数据一致性吗?

问答 2023-01-15 来自:开发者社区

对于Flink CDC,请问下你们同步是一个表对应一个topic还是一个库对应一个topic?

对于Flink CDC,请问下你们同步是一个表对应一个topic还是一个库对应一个topic?

问答 2023-01-09 来自:开发者社区

Flink CDC cdc单表同步es 报这个为啥?

Flink CDC cdc单表同步es 报这个为啥?

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

产品推荐

阿里云实时计算Flink

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

+关注