开发者社区> 问答> 正文

使用CanalKafkaClientExample storeValue是乱码

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

展开
收起
Java工程师 2023-05-08 19:05:13 101 0
1 条回答
写回答
取消 提交回答
  • storeValue是com.alibaba.otter.canal.protocol.RowChange类型,需要进一步解析出来,具体可以看EntryProtocol.proto中的定义

    原回答者GitHub用户littleneko

    2023-05-09 19:05:07
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载