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

Flink CDC source 端和sink端应该怎么做呢?

Flink CDC中datastream cdc 采集不同mysql实例的分库分表到同一个topic,source 端和sink端应该怎么做呢? 一个source只能对一个实例然后合并sink吗?

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

Flink CDC读取数据有限流的配置么,发现cdc读取太快,sink慢导致反压了,不知道咋解决了?

问题1:Flink CDC读取数据有限流的配置么,发现cdc读取太快,sink慢导致反压了,不知道咋解决了?问题2:这个快照是针对全量阶段/增量阶段 , 还是说都可以呢

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

Flink CDC读取数据有限流的配置么,发现cdc读取太快,sink慢导致反压了?

Flink CDC读取数据有限流的配置么,发现cdc读取太快,sink慢导致反压了?

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

Flink CDC如何自定义sink批量写入呢?

Flink CDC如何自定义sink批量写入呢?

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

Flink CDC 有人用过upsert-kafka做为sink端吗?

Flink CDC 有人用过upsert-kafka做为sink端吗。我用upsert-kafka做为sink端时,启了一个消费者去观察flink写入的那个topic,貌似没有实时捕获数据。只有重新启动flink sql-client,才能把新插入的数据捕获,但是历史的数据又会重新获取一遍?

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

请教一下,Flink CDC 中如果Greenplum的Postgres版本号为9.4,是不是就不?

请教一下,Flink CDC 中如果Greenplum的Postgres版本号为9.4,是不是就不能做为Flink的Sink端啊,因为这个版本还不支持upsert语法?也就是说,pg版本为9.5以下的GP,不能做sink是么,我看日志直接报错。主键倒是支持啊,就是不支持upsert语法

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

有老铁Flink CDC中碰到过sink hudi 同步hive失败吗 看不到hive 表 ?

有老铁Flink CDC中碰到过sink hudi 同步hive失败吗 看不到hive 表 但是手动映射hudi文件 又能成功 sync和mr包都放了?

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

Flink CDC有sink到kafka的方法吗?我看官方的就是要引入flink-connector

Flink CDC有sink到kafka的方法吗?我看官方的就是要引入flink-connector-kafk

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

Flink CDC sink doris如何解决?

Flink CDC sink doris如何解决?

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

Flink CDC中sink能写多张表吗?

Flink CDC中sink能写多张表吗?

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

产品推荐

阿里云实时计算Flink

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

+关注