Drainer Kafka: Parsing Data in Kafka with Java

This topic has been translated from a Chinese forum by GPT and might contain errors.

Original topic: drainer kafka java解析kafka中数据

| username: kuweilong666

How does Java parse data from Kafka coming from the drainer?

| username: 小王同学Plus | Original post link

You can refer to this document Binlog Consumer Client 用户文档 | PingCAP 文档中心 to check the specific definition of the data format. You can also refer to this https://github.com/pingcap/tidb/blob/master/tidb-binlog/proto/proto/secondary_binlog.proto