关于解析kafka中的binlog消息

官方提供了 protobuf 文件
https://github.com/pingcap/tidb-tools/blob/release-4.0/tidb-binlog/proto/proto/binlog.proto

你可以通过这个文件来生成解析格式,如果你会 python,生成 python 能够操纵的 api 和 数据格式

然后你贴的这串码,就可以解开了


如果你身边有懂 Java 的小伙伴,可以求助一下,
https://github.com/pingcap/tidb-tools/tree/release-4.0/tidb-binlog/driver/example/kafkaReader

这里一份 kafkaReader example ,对着改改就可以用了