文章目录
- 消费进度如何管理的？
- 老消费者组继续消费的管理方式
- 新消费者组初始消费的管理方式
- 解决建议
- 总结
消费进度如何管理的？
RocketMQ是以consumer group queue为单位是管理消费进度的，以一个consumer offset标记这个这个消费组在这条queue上的消费进度。 如果某已存在的消费组出现了新消费实例的时候，依靠这个组的消费进度，就可以判断第一次是从哪里开始拉取的。
总结起来话，有以下关键点
- 消费进度存储在broker端（CLUSTER模式），以消费者组 queue的单位存储。类似：
{
"offsetTable":{
"TopicTest@pullConsumerGroupTest":{
