Kafka的message格式是什么样的

参考答案

一个 KafkaMessage ,是由一个固定长度的 header 和 一个变长的消息体 body 组成的。

header:

  • 由一个字节的magic(文件格式)和四个字节的CRC32(用于判断body消息体是否正常)构成。
  • 当magic的值为1的时候,会在magic和crc32之间多一个字节的数据:attributes(保存一些相关属性,比如是否压缩、压缩格式等等);如果magic的值为0,那么不存在attributes属性。

body:

  • 由N个字节构成的一个消息体,包含了具体的key/value消息

以上,是 Kafka 面试题【Kafka的message格式是什么样的】的参考答案。

输出,是最好的学习方法

欢迎在评论区留下你的问题、笔记或知识点补充~

—end—

0 条回复 A文章作者 M管理员
    暂无讨论,说说你的看法吧