Flink CDC-消费kafka数据（debezium格式） 这样能删掉吗?
Flink CDC-消费kafka数据（debezium格式） 主键是双主键的 id 和 user 比如新增一条 id=1 user=123 有其他人删除了id=1的这个数据 删除的主键内容就是 id=1 user=124 这样能删掉吗?
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
-
在 Flink CDC 中，消费 Kafka 中的 Debezium 格式数据进行变更捕获时，如果你新增一条 id=1 user=123 的数据，同时有其他人删除了 id=1 的数据，即删除的主键内容是 id=1 user=124，那么这样是可以正确删除对应的数据的。
Flink CDC 会根据 Debezium 格式的数据变更事件进行解析，并根据事件中的主键信息来执行相应的操作。在你的示例中，当 Flink CDC 接收到删除事件 id=1 user=124 时，它会根据该主键信息来进行删除操作，并确保删除对应的数据。
需要注意的是，Flink CDC 默认情况下会将主键信息作为事件的 Key，而不是作为事件的 Value。因此，在数据流中，每个事件的 Key 包含主键信息，用于唯一标识记录。Flink CDC 根据 Key 来执行插入、更新或删除操作。
请确保在 Flink CDC 任务中配置了正确的主键信息，以便它能够正确解析和处理 Debezium 格式的数据。如果主键信息没有正确配置，可能会导致数据处理错误或不一致。
总结来说，Flink CDC 可以根据 Debezium 格式的数据变更事件中的主键信息正确执行删除操作，并删除对应的数据。
2023-09-19 11:45:03赞同 展开评论
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。