为提高效率,请提供以下信息,问题描述清晰能够更快得到解决:
【 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/)
若提问为性能优化、故障排查类问题,请下载脚本运行。终端输出的打印结果,请务必全选并复制粘贴上传。