消息体小且存储结构面向单 条消息，导致提升吞吐困难 • 在进行状态存储时，无 KV 语义支撑 挑战 • Commitlog 格式存储， 统一复制算法 • 不借助外部依赖，提供 状态存储能力 • 单一数据文件，支持面向流的索引及面向 批的索引 • 批量发，批量存，批量读，吞吐提升十倍 • 统一消息，KV 语义，统一 API，提供 状态存储能力 • 流表二象性支持 W r i t e

0，并不会执行 CONSUME_FROM_LAST_OF FSET(语义)。 代码@3：如果 lastOffset 为-1,表示当前并未存储其有效偏移量，可以理解为第一次 消费，如果是消费组重试主题，从重试队列偏移量为 0 开始消费；如果是普通主题，则从 队列当前的最大的有效偏移量开始消费，即 CONSUME_FROM_LAST_OFFSET 语义 的实现。 代码@4：如果从远程服务拉取最大偏移量拉取异常或其他情况，则使用-1