pull log是如何实现consumer扩所容的？如何保证consumer queue log的offset正确推进？

[cnkeeper]

问题描述
pull log是如何实现consumer扩所容的？如何保证consumer queue log的offset正确推进？可以简单介绍下吗

环境配置

复现步骤
1.
2.
3.

实际输出结果

期望输出结果

[keliwang]

consume queue 的推进并不依赖 pull log，而是每个 consumer group 都会维护一个当前的消费进度。每次一个 consumer 来拉取消息，都会从当前消费进度开始分配消息，然后将分配的消息记录到 pull log 中，consumer group 里每个 consumer 的 pull log 都是独立的。