RocketMQ 的 CONSUME_FROM_LAST不生效问题

文章目录

• 消费进度如何管理的？
• 老消费者组继续消费的管理方式
• 新消费者组初始消费的管理方式
• 解决建议
• 总结

消费进度如何管理的？

RocketMQ是以consumer group+queue为单位是管理消费进度的，以一个consumer offset标记这个这个消费组在这条queue上的消费进度。 如果某已存在的消费组出现了新消费实例的时候，依靠这个组的消费进度，就可以判断第一次是从哪里开始拉取的。

总结起来话，有以下关键点

1. 消费进度存储在broker端（CLUSTER模式），以消费者组+queue的单位存储。类似：

{
   
	"offsetTable":{
   
		"TopicTest@pullConsumerGroupTest":{