Flink CDC-消费kafka数据（debezium格式） 这样能删掉吗?

在 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 格式的数据变更事件中的主键信息正确执行删除操作，并删除对应的数据。