Kafka 的消息格式,在 Java 中,用 DefaultRecordBatch 表示。

代码地址:https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java

关于消息格式的官方文档:https://kafka.apache.org/documentation/#messageformat