消费者

librdkafka 消费者在自己的线程上预先拉取，每次轮询交出一条记录，并按计时器提交已存储的偏移量。

以文字阅读本图

1. librdkafka 线程: 拉取 已分配的分区; 本地队列 预先拉取; 自动提交 按计时器， 每 5 秒
2. 应用: 轮询 下一条记录; 处理 这条记录; 偏移量存储 在内存中， 每个分区 一个位置
3. Kafka 集群 分区 leader、组协调者 → 拉取 已分配的分区: 记录
4. 拉取 已分配的分区 → 本地队列 预先拉取
5. 本地队列 预先拉取 → 轮询 下一条记录
6. 轮询 下一条记录 → 处理 这条记录
7. 轮询 下一条记录 → 偏移量存储 在内存中， 每个分区 一个位置: 交出时
8. 处理 这条记录 → 偏移量存储 在内存中， 每个分区 一个位置: 或稍后
9. 偏移量存储 在内存中， 每个分区 一个位置 → 自动提交 按计时器， 每 5 秒: 读取
10. 自动提交 按计时器， 每 5 秒 → Kafka 集群 分区 leader、组协调者: 提交

librdkafka 在应用请求之前，就把已分配分区的记录拉取到本地队列中。queued.max.messages.kbytes（64 MiB）限制这个队列的大小。队列满时，对某个分区的拉取暂停 fetch.queue.backoff.ms（一秒）。

一次轮询从队列中取出下一条记录。rust-rdkafka 的 StreamConsumer 通过 recv 完成这一步，这是一个取消安全的异步调用。

偏移量存储是每个分区在内存中的一个位置。默认情况下（enable.auto.offset.store），轮询在应用处理记录之前，就存储它交出的那条记录的偏移量。虚线箭头是另一种方式：应用关闭自动存储，在记录处理完之后再存储偏移量。

enable.auto.commit 开启时，计时器每隔 auto.commit.interval.ms（五秒）提交一次已存储的位置，消费者关闭时再提交一次。崩溃会丢失上次提交之后已处理的进度，这部分记录会被再读一遍。在默认的存储方式下，交出时已存储、尚未处理的记录在崩溃后会被跳过。

行为和默认值来自 librdkafka（偏移量管理、配置）。