Flink CDC删除同步到es里数据的原理是什么呢？

Flink CDC 是一个基于 Apache Flink 的开源工具，用于将关系型数据库的变更数据（如增、删、改）实时同步到 Elasticsearch（ES）等目标存储。同步过程中，如果在源数据库中删除了 product 表的记录，则 Flink CDC 会通过变更数据捕获到该删除操作，并在同步到 ES 时进行相应的删除操作。

具体而言，Flink CDC 通过监听数据库的 binlog（或者使用其他方式），捕获到数据库的变更数据，并将其转换成对应的 Elasticsearch 的操作（如 Index、Delete、Update）。

在删除操作的情况下，Flink CDC 会根据删除记录的主键或唯一标识，生成对应的删除操作指令，即对应的 Elasticsearch 的 Delete 操作。这样，当数据同步到 ES 时，ES 会根据删除操作指令删除对应的记录。

关于 Flink CDC 的具体实现细节和原理，可以参考 Flink CDC 的官方文档、源代码或相关的开发者社区讨论。您可以通过搜索 "Flink CDC" 或者 "Flink CDC implementation" 来获取更多的资料和参考资源。另外，您还可以参考 Flink 官方文档中关于 CDC 的章节，了解 CDC 的工作原理和实现机制。