OB flink cdc 问题咨询

[11小透明]

【测试环境】

【 OB 】

【 4.2.1】

【问题描述】

怎么通过flink cdc data stream方式拿到足够的信息：

1.操作类型

2.对应时间戳

[川粉]

时间戳可以用 metadata 列 https://nightlies.apache.org/flink/flink-cdc-docs-release-3.0/docs/connectors/legacy-flink-cdc-sources/oceanbase-cdc/#available-metadata

操作类型暂时拿不到

[11小透明]

Column.physical(“op_ts”, DataTypes.TIMESTAMP()) 是这样拿吗