如何通过OceanBase CDC DataStream Source获取增量数据的事务ID

【测试环境】

【 OB 】

【 4.2.1】

【问题描述】

如何通过OceanBase CDC DataStream Source获取增量数据的事务ID,存到另一张表里

目前已有的解析函数没有处理事务id,所以是拿不到的。

那还有什么方法么,能把增量的数据的事务ID保存下来就成

这个需要改解析的函数了,因为已有的 cdc 工具都是用时间戳来作为位点的,没有处理过事务id。

自己写代码调用Logproxyclient是不是也行

自定义客户端逻辑是可以的,Logproxyclient 接收到的数据会转成 LogMessage 格式,里面的 getOB10UniqueId 就是获取事务 id 的函数。