AI 助理
备案控制台
开发者社区 问答 正文

问下各位大佬，你们拿到cdc的source消息后是怎么处理的？是在process里面连接目的数据库还

问下各位大佬，你们拿到cdc的source消息后是怎么处理的？是在process里面连接目的数据库还是另外写一个sink？

展开
收起
真的很搞笑 2023-04-19 17:20:07 180 分享 版权
来自： 阿里云实时计算Flink

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

1 条回答
写回答
取消 提交回答
  • TiAmoZhang
    CSDN全栈领域优质创作者，万粉博主；InfoQ签约博主；华为云享专家；华为Iot专家；亚马逊人工智能自动驾驶（大众组）吉尼斯世界纪录获得者

    一般来说，CDC(Change Data Capture)是一种用于捕获数据库更改的技术，它可以实时地将数据库中的更改记录下来并传输到其他系统或应用程序中。因此，当CDC接收到源消息时，它会根据源消息的内容进行相应的处理，例如更新缓存、触发事件等。具体的处理方式取决于应用程序的需求和设计。

    2023-06-30 09:55:19
    赞同 展开评论
问答分类：
数据库
问答标签：
数据库连接 数据库cdc 数据库source 数据库怎么处理
问答地址：
开发者社区 > 阿里云实时计算Flink > 问答
相关问答
RDS数据库创建账号报错提示Message : 参数DBDescription无效怎么处理
114
1
0
在PolarDB通过导入表空间的方式还原数据库，报错把服务整挂了，现在启动报错，应该怎么处理？
83
1
0
Flink CDC里我数据库设置的字段类型是decimial为什么打印出来是乱码?
136
1
0
在Flink CDC中cdc 去接postgrep 分库分表，需要分别给分数据库创建source吗？
100
1
0
OceanBase数据库中，sqoop脚本使用-m参数报错怎么处理？
125
0
0
rds数据库转按量付费报错怎么处理
83
1
0
OceanBase数据库中，大家生产环境有漏扫吗？扫出40多个高危漏洞怎么处理？
132
0
0
polar DB 表误删数据，按表恢复提示 “当前全球数据库节点角色不支持该操作”，怎么处理？
79
1
0
OceanBase数据库这个报错怎么处理？
55
1
0
OceanBase数据库这个怎么处理？
76
2
0