Kafka消息偏移量的演变

一、Kafka 0.7.x 1、非压缩消息 MessageSet 格式的时候就说Offset字段存储的是消息存储到磁盘之后的物理偏移量 从上图可以看出,每条消息存在磁盘的偏移量是其距离文件开头的绝对偏移量。比如上面第一条消息的偏移量是0;第二条消息的偏移量是第一条消息的总长度;第三条消息是其前两条消息总长度;以此类推。这种方式存储消息的偏移量很好理解,处理起来也很方便。 消息存储到磁盘的偏移量是由
相关文章
相关标签/搜索