有大佬知道flink-cdc 原表删除的时候获取到的是什么数据啊
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
当使用Flink CDC处理MySQL等数据库的Change Data Capture (CDC)时,如果原表有数据被删除,Flink CDC能够捕获到这一变更事件,并将其表示为一个删除(DELETE)事件。在Flink CDC的数据流中,该删除事件通常包含以下信息:
因此,当你通过Flink CDC监听到数据源的删除操作时,实际上获取的是表示该删除行为的事件数据包,而非原数据的实体内容,但包含了足够的信息来识别和反应这次删除操作。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。