FlinkCDC 从mysql 怎么知道是删除，添加操作

在FlinkCDC中，从MySQL中抽取数据时，可以通过监控MySQL的二进制日志（Binary Log）来获取数据的增删改操作，具体流程如下：

1. 启用MySQL的Binary Log：在MySQL中，需要启用Binary Log功能，即在MySQL的配置文件中添加如下配置：

log-bin=mysql-bin
binlog-format=ROW

2. 创建FlinkCDC任务：通过FlinkCDC的API或者控制台，创建一个FlinkCDC任务，并指定MySQL的JDBC连接信息。

3. 配置MySQL的binlog信息：在FlinkCDC任务中，需要指定MySQL的binlog信息，包括binlog的文件名（filename）和偏移量（position），以及解析binlog的模式（mode），例如Row、Statement、Mixed等。

4. 数据抽取：FlinkCDC会从MySQL的binlog中抽取数据，并将数据转换为Changelog格式。在Changelog中，每一条数据都包含了数据的增删改操作类型（INSERT、UPDATE、DELETE）、表名、主键值以及列名和列值等信息。

5. 数据同步：FlinkCDC将转换后的数据写入到指定的Sink中，例如Kafka、HBase、MySQL等，实现数据的增量同步。

综上所述，通过监控MySQL的binlog，FlinkCDC可以实现对MySQL数据的增删改操作的监控和同步。需要注意的是，在使用FlinkCDC抽取MySQL数据时，需要确保MySQL的binlog功能已经启用，并且FlinkCDC任务已经正确配置binlog信息。