binlog日志 Cdcpb.Event.Row 这种结构的数据如何解析

为提高效率,请提供以下信息,问题描述清晰能够更快得到解决:
【 TiDB 使用环境】

v5.4.0
【概述】 场景 + 问题概述
用flink cdc 获取 tidb 日志
【应用框架及开发适配业务逻辑】
TIDB bin-log ====> flink(TiDBSource方式)===>
【背景】 做过哪些操作

【现象】 业务和数据库现象
变更一个 数据库表的字段时 会发出日志
【问题】 当前遇到的问题
TiDBSource方式。 Cdcpb.Event.Row record 这个类型的数据如何去解析获取到真实的数据
这是我输出日志的方式:
System.out.println(“Row:” + record.toString());

start_ts: 433741673326968834
commit_ts: 433741673326968835
type: COMMITTED
op_type: PUT
key: “t\200\000\000\000\000\000\000?_r\200\000\000\000\000\000\000\021”
value: “\200\000\006\000\000\000\002\003\004\005\006)\v\000\023\000\037\000#\000*\000+\0001111111231232323232ewewew222eww2131dwwerwe\000”
old_value: “\200\000\006\000\000\000\002\003\004\005\006)\v\000\023\000\037\000(\000/\0000\0001111111231232323232ewewew222eww132sd3123dwwerwe\000”
【业务影响】

【TiDB 版本】

【附件】 相关日志及监控(https://metricstool.pingcap.com/)


若提问为性能优化、故障排查类问题,请下载脚本运行。终端输出的打印结果,请务必全选并复制粘贴上传。

参考下这个
https://docs.pingcap.com/zh/tidb/stable/binlog-consumer-client

不过,好像CDC 会用的比 binlog 要多点,而且5.X 不在支持 binlog了…

也就是流程就直接变成TIDB ==》kafka ==〉消费到其他地方。只能这种流程了是吧?

对,基本上就相当于 变更事件推送了

如果需要 CDC 的方式来做流式计算,这样子也会比较合适.

binlog 和 Ticdc 的格式是不一样,得注意一下