2018-10-10 17:25:19.304 [Thread-2] INFO c.a.o.canal.client.running.kafka.CanalKafkaClientExample - Message[id=16,entries=[header { version: 1 logfileName: "mysql-bin.000156" logfileOffset: 298158292 serverId: 1 serverenCode: "UTF-8" executeTime: 1539163519000 sourceType: MYSQL schemaName: "payment" tableName: "tmp_canal_test" eventLength: 69 eventType: UPDATE props { key: "rowsCount" value: "1" } } entryType: ROWDATA storeValue: "\b\242\006\020\002P\000b\341\001\n\033\b\000\020\004\032\002id \001(\0000\000B\00245R\aint(11)\n'\b\001\020\f\032\busername \000(\0000\000B\003111R\fvarchar(255)\n*\b\002\020\f\032\bpassword \000(\0000\000B\006123123R\fvarchar(255)\022\033\b\000\020\004\032\002id \001(\0000\000B\00245R\aint(11)\022'\b\001\020\f\032\busername \000(\0000\000B\003111R\fvarchar(255)\022'\b\002\020\f\032\bpassword \000(\0010\000B\003123R\fvarchar(255)" ],raw=true,rawEntries=[]]
请问一下怎么处理
原提问者GitHub用户xiaoqitu7
storeValue是com.alibaba.otter.canal.protocol.RowChange类型,需要进一步解析出来,具体可以看EntryProtocol.proto中的定义
原回答者GitHub用户littleneko
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。