【测试环境】
【 OB 】
【 4.2.1】
【问题描述】
如何通过OceanBase CDC DataStream Source获取增量数据的事务ID,存到另一张表里
【测试环境】
【 OB 】
【 4.2.1】
【问题描述】
如何通过OceanBase CDC DataStream Source获取增量数据的事务ID,存到另一张表里
目前已有的解析函数没有处理事务id,所以是拿不到的。
那还有什么方法么,能把增量的数据的事务ID保存下来就成
这个需要改解析的函数了,因为已有的 cdc 工具都是用时间戳来作为位点的,没有处理过事务id。
自己写代码调用Logproxyclient是不是也行
自定义客户端逻辑是可以的,Logproxyclient 接收到的数据会转成 LogMessage 格式,里面的 getOB10UniqueId 就是获取事务 id 的函数。