Kafka 存储在硬盘上的消息格式是什么?

消息由一个固定长度的头部和可变长度的字节数组组成。头部包含了一个版本号和 CRC32校验码。
1.消息长度: 4 bytes (value: 1+4+n)
2.版本号: 1 byte
3CRC 校验码: 4 bytes
4.具体的消息: n bytes

发表评论

后才能评论