标签: 消息队列
Kafka 存储与消费模型
Kafka 的高性能依赖于「分区日志 + 顺序写 + 批量拉取」的设计。理解存储与消费模型，才能合理配置并行度与避免重复消费。 Topic 与 Partition topic 是逻辑主题，partition 是物理并行单位，消息只追加写入分区末尾。 每个分区是一个有序、不可变的日志，由多个 segment 文件组成，并维护 offset（分区内唯一递增）。 分区数决定了消费的并行上限：一个分区同一时刻只被 group 内一个消费者消费。 Offset 与消费位移 消费者处理完消息后提交的位移称为 …
Kafka 的高性能依赖于「分区日志 + 顺序写 + 批量拉取」的设计。理解存储与消费模型，才能合理配置并行度与避免重复消费。 Topic 与 Partition topic 是逻辑主题，partition 是物理并行单位，消息只追加写入分区末尾。 每个分区是一个有序、不可变的日志，由多个 segment 文件组成，并维护 offset（分区内唯一递增）。 分区数决定了消费的并行上限：一个分区同一时刻只被 group 内一个消费者消费。 Offset 与消费位移 消费者处理完消息后提交的位移称为 …