美文网首页
【Kafka官方文档翻译】5.5.3. 消息

【Kafka官方文档翻译】5.5.3. 消息

作者: FlySheep_ly | 来源:发表于2017-06-21 18:48 被阅读47次

    原文地址:https://kafka.apache.org/0101/documentation.html#messages
      消息包含一个固定大小的头,一个变长且“不透明”的byte数组表示的key和一个变长且“不透明”的byte数组表示的内容。header包含以下内容:

    • A CRC32 checksum to detect corruption or truncation.
    • A format version.
    • An attributes identifier
    • A timestamp

    保持key和value的不透明是正确的决定:现在序列化方面取得了巨大的进展,选择特定的一个序列化方式都不太适合所有的场景。不用说使用Kafka的特定程序可能需要特定的序列化方式。MessageSet接口是批量读写消息到NIO Channel的迭代器。

    相关文章

      网友评论

          本文标题:【Kafka官方文档翻译】5.5.3. 消息

          本文链接:https://www.haomeiwen.com/subject/mmmtcxtx.html