Kafka Message(消息)有哪几部分组成?

  • CRC32:4个字节,消息的校验码。

  • magic:1字节,魔数标识,与消息格式有关,取值为0或1。当magic为0时,消息的offset使用绝对offset且消息格式中没有timestamp部分;当magic为1时,消息的offset使用相对offset且消息格式中存在timestamp部分。所以,magic值不同,消息的长度是不同的。

  • attributes: 1字节,消息的属性。其中第0~ 2位的组合表示消息使用的压缩类型,0表示无压缩,1表示gzip压缩,2表示snappy压缩,3表示lz4压缩。第3位表示时间戳类型,0表示创建时间,1表示追加时间。

  • timestamp: 时间戳,其含义由attributes的第3位确定。

  • key length:消息key的长度。

  • key:消息的key。

  • value length:消息的value长度。

  • value:消息的内容

相关文章:

  • 2021-05-18
  • 2021-06-07
  • 2022-02-08
  • 2022-01-22
  • 2021-07-26
  • 2021-11-19
  • 2021-04-18
猜你喜欢
  • 2021-08-06
  • 2021-11-01
  • 2021-11-20
  • 2021-07-12
  • 2021-11-14
  • 2021-12-24
  • 2021-06-22
相关资源
相似解决方案