更新时间:2024-04-08 GMT+08:00

重置消费进度

操作场景

重置消费进度即修改消费者的消费位置。

重置消费进度可能会导致重复消费,请谨慎操作。

操作步骤

  1. 登录管理控制台。
  2. 在管理控制台左上角单击,选择区域。

    请选择RocketMQ实例所在的区域。

  3. 在管理控制台左上角单击,选择“应用服务 > 分布式消息服务 RocketMQ”,进入分布式消息服务RocketMQ专享版页面。
  4. 单击RocketMQ实例的名称,进入实例详情页面。
  5. 在左侧导航栏,单击“消费组管理”,进入消费组列表页面。
  6. 在待重置消费进度的消费组所在行,单击“更多 > 重置消费进度”,弹出“重置消费进度”对话框。
  7. 参考表1,设置重置消费进度参数。

    表1 重置消费进度参数说明

    参数

    说明

    Topic名称

    选择待重置消费进度的Topic。

    时间

    选择重置消费进度的时间点,重置完成后,将从此时间点开始消费。

    • 自定义:自定义时间点
    • 最早:最早偏移量
    • 最晚:最晚偏移量

  8. 单击“确定”,弹出“重置消费进度确认”对话框。
  9. 单击“是”,完成消费进度的重置。