更新时间:2025-07-29 GMT+08:00
重置RocketMQ消费进度
重置RocketMQ消费进度即修改消费者的消费位置,重置消费进度后,消费者会从修改后的消息位置开始继续消费。
背景信息
RocketMQ通过消费位点管理消息的消费进度。每条消息被某个消费者消费完成后不会立即在队列中删除,RocketMQ会基于每个消费组维护一份消费记录,该记录指定了消费组下的消费者消费指定Topic时,消费过的最新一条消息的位点,即消费位点。当消费者客户端离线又再次重新上线时,消费者会严格按照服务端保存的消费进度继续处理消息。
如果希望重新消费或跳过消费部分消息,您可以通过重置消费位点调整您的消费进度。
操作视频
本视频演示重置RocketMQ消费进度的操作。
约束限制
- 重置消费位点的范围是重置指定消费组对于目标Topic的消费位点,因此不会影响其他订阅了该Topic的消费组的消费进度。
- 广播消费模式下不支持重置消费位点。
- 重置消费位点功能只能重置对消费者可见的消息,不能重置定时中、重试等待中的消息。
- 重试消费位点只能在消费者在线时进行操作。
重置RocketMQ消费进度
- 登录管理控制台。
- 在管理控制台左上角单击
,选择区域。
不同区域的云服务产品之间内网互不相通。请就近选择靠近您业务的区域,可减少网络时延,提高访问速度。
- 在管理控制台左上角单击
,选择“应用中间件 > 分布式消息服务RocketMQ版”,进入分布式消息服务RocketMQ页面。
- 单击RocketMQ实例的名称,进入实例详情页面。
- 在左侧导航栏,单击“实例管理 > 消费组管理”,进入消费组列表页面。
- 在待重置消费进度的消费组所在行,单击“重置消费进度”,弹出“重置消费进度”对话框。
- 参考表1,设置重置消费进度参数。
- 单击“确定”,弹出“重置消费进度确认”对话框。
重置消费进度可能会导致重复消费,请谨慎操作。
- 单击“是”,完成消费进度的重置。
相关文档
重置消费进度也可以通过调用API完成,具体请参见重置消费进度。