flink-cdc在2.x版本在mysq-cdc connetor中如何获取row_kind列？

Apache Flink CDC Connector 在 2.x 版本中对于 MySQL CDC 的实现并未直接提供 row_kind（行类型）这个元数据列，这是因为在早期版本中，Flink CDC 主要是通过解析 MySQL Binlog 的事件类型来区分插入、更新和删除操作，这些信息在 Flink 内部处理时被用来构建相应的流处理逻辑。

尽管如此，你仍然可以通过 Flink SQL API 或者 DataStream API 间接获取行级别操作的类型信息。在 2.x 版本的 MySQL CDC 连接器中，对于每条变更记录，虽然没有直接提供 row_kind 字段，但它可以根据不同的 Binlog 事件类型来推断数据的变化类型。

在处理 CDC 流时，可以通过 Flink 的内置逻辑或者自定义的 MapFunction、ProcessFunction 等进行逻辑判断和处理，根据每条记录携带的信息（如 before/after image 或者 update/insert/delete 标记）来决定如何处理数据。

对于更加方便地处理 CDC 数据的需求，在 Flink 3.0 及以后的版本中，MySQL CDC 连接器进行了改进，新增了 row_kind 元数据列，使得开发者可以直接在 SQL 查询中使用该列来区分不同类型的操作，简化了流处理逻辑的设计和实现。对于 2.x 版本，若需实现类似功能，可能需要自定义逻辑来模拟这一行为。