实时计算 Flink版产品使用合集之同步数据库时，库名称变了，route只能到表级别，怎么解决-阿里云开发者社区

实时计算 Flink版产品使用合集之同步数据库时，库名称变了，route只能到表级别，怎么解决

2024-05-23 180

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 实时计算Flink版作为一种强大的流处理和批处理统一的计算框架，广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStreamAPI、以及与上下游数据源和存储系统的丰富连接器，提供了一套全面的解决方案，以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点，使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。

问题一：Flink CDC postgresql-cdc这两个配置有什么关系吗？

Flink CDC postgresql-cdc中heartbeat.interval.ms配置与deberzium中这两个配置有什么关系吗？

参考答案：

我理解没啥区别，flink-connector-pgsql-cdc是基于debezium开发出来的

关于本问题的更多回答可点击进行查看：

https://developer.aliyun.com/ask/584495

问题二：Flink CDC想同步的数据，加上特别的字段，可以加吗？

Flink CDC想同步的数据，加上特别的字段，可以加吗？

参考答案：

关于本问题的更多回答可点击进行查看：

https://developer.aliyun.com/ask/584494

问题三：Flink CDC有办法直接匹配库吗？

Flink CDC有办法直接匹配库吗？

参考答案：

好像是不支持的，一般变库名的不常见，可以加profiex，ods_

关于本问题的更多回答可点击进行查看：

https://developer.aliyun.com/ask/584491

问题四：Flink CDC同步数据库，库名称变了，route只能到表级别，哪里能改吗？

Flink CDC同步数据库，库名称变了，route只能到表级别，哪里能改吗？

参考答案：

这个可以自己做下二开支持的哈这一块的逻辑不复杂，

我这边是搞了个mapper 优先route 规则然后指定库映射和表名统一前缀后缀

关于本问题的更多回答可点击进行查看：

https://developer.aliyun.com/ask/584488

问题五：Flink CDC指点一下呗？

Flink CDC指点一下呗？

参考答案：

如果是 Datastream 作业，则需要根据不同的 Flink 版本引入不同版本的 flink-shaded-guava 依赖，DataStream 用户可以参考 SQL Connector 的打包方式管理正确的依赖。

关于本问题的更多回答可点击进行查看：

https://developer.aliyun.com/ask/584484

相关实践学习

基于Hologres+Flink搭建GitHub实时数据大屏

通过使用Flink、Hologres构建实时数仓，并通过Hologres对接BI分析工具（以DataV为例），实现海量数据实时分析.

实时计算 Flink 实战课程

如何使用实时计算 Flink 搞定数据处理难题？实时计算 Flink 极客训练营产品、技术专家齐上阵，从开源 Flink功能介绍到实时计算 Flink 优势详解，现场实操，5天即可上手！欢迎开通实时计算 Flink 版： https://cn.aliyun.com/product/bigdata/sc Flink Forward Asia 介绍： Flink Forward 是由 Apache 官方授权，Apache Flink Community China 支持的会议，通过参会不仅可以了解到 Flink 社区的最新动态和发展计划，还可以了解到国内外一线大厂围绕 Flink 生态的生产实践经验，是 Flink 开发者和使用者不可错过的盛会。去年经过品牌升级后的 Flink Forward Asia 吸引了超过2000人线下参与，一举成为国内最大的 Apache 顶级项目会议。结合2020年的特殊情况，Flink Forward Asia 2020 将在12月26日以线上峰会的形式与大家见面。