Hi,

RT,对于data stream 消费binlog得到的sourceRecord,是一些string类型的struct类型数据,
 请问官方有什么好的办法去解析这些string类型的struct数据吗?使用反射? 目标是解析成Java对象。

附上数据:

SourceRecord{sourcePartition={server=mysql_binlog_source},
sourceOffset={file=mysql-bin.000001, pos=720, row=1, snapshot=true}}
ConnectRecord{topic='mysql_binlog_source.flink_cdc.student',
kafkaPartition=null, key=Struct{id=1},
keySchema=Schema{mysql_binlog_source.flink_cdc.student.Key:STRUCT},
value=Struct{after=Struct{id=1,name=fisher,age=28},source=Struct{version=1.4.1.Final,connector=mysql,name=mysql_binlog_source,ts_ms=0,snapshot=true,db=flink_cdc,table=student,server_id=0,file=mysql-bin.000001,pos=720,row=0},op=c,ts_ms=1631845080195},
valueSchema=Schema{mysql_binlog_source.flink_cdc.student.Envelope:STRUCT},
timestamp=null, headers=ConnectHeaders(headers=)}


BR
Fisher

Reply via email to