问答 2024-06-25 来自:开发者社区

在Flink CDC中我的场景是把变更数据抽到Kafka进行实时计算,这种脏数据应该咋处理?

在Flink CDC中我的场景是把变更数据抽到Kafka进行实时计算,这种脏数据应该咋处理?

问答 2024-06-14 来自:开发者社区

企业版Flink CDC能从Hologress捕获变更数据到kafka或datahub吗

企业版Flink CDC能从Hologress捕获变更数据到kafka或datahub吗

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

Flink CDC一个场景中需要关联十几张表并聚合,每次变更都会更新到Kafka很多数据?

Flink CDC一个场景中需要关联十几张表并聚合,我现在使用了upsertkafaka将这个大融合切成多个,但是现在问题是这样每个新任务基于上次的upsert Kafka数据量非常大,每次变更都会更新到Kafka很多数据?有没有更好的方式比如结合ice格式的流融合?es8 table connector pls不想走中转感觉走upsertKafka会变慢?

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

Flink CDC中这个监听的数据变更是默认丢到kafka 里面吗? 我该已什么方式去获取到这个表

Flink CDC中这个监听的数据变更是默认丢到kafka 里面吗? 我该已什么方式去获取到这个表更消息的呀 大佬们 我用的 flink 2.4 flinkcdc 1.6.2

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

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注