全部产品
阿里云办公

重置消费位点

更新时间:2019-01-16 20:44:06

如果想跳过堆积的消息,即不想消费这部分消息,或者只想消费某个时间点之后的消息(不论之前是否消费过这些消息),您可以使用重置消息的消费位点。 具体操作步骤如下:

  1. 在消息队列 RocketMQ 控制台的左侧导航栏,选择Group 管理

  2. 找到需要重置消费位点的 Group ID 和针对的 Topic,在该行的操作列中单击更多功能>重置消费位点

  3. 重置消费位点对话框中,根据需求选择“清除所有堆积消息,从最新位点开始消费”或“按时间段进行消费位点重置”。关于这两个选项的具体说明如下:

    • 清除所有堆积消息,从最新位点开始消费:若选择此项,该 Group ID 在消费该 Topic 下的消息时会跳过当前堆积(未被消费)的所有消息,从这之后发送的最新消息开始消费。

      注意:对于程序返回 “reconsumeLater”,即走重试流程的这部分消息来说,清除无效。

    • 按时间点进行消费位点重置:点击该选项后会出现时间点选择的控件。请选择一个时间点,这个时间点之后发送的消息才会被消费。

      注意:

      • 可选时间范围中的起始和终止时间分别是该 Topic 中储存的最早的和最晚的一条消息的生产时间。

      • 若选择的时间点超出标明的可选时间范围,系统会默认按以下逻辑进行处理:

        • 若选择的时间点早于可选时间范围的起始时间:将消费位点重置到可选时间范围的起始时间。

        • 若选择的时间点晚于可选时间范围的终止时间:将消费位点重置到可选时间范围的终止时间。

  4. 单击确定执行消费位点重置。

说明:目前不支持指定 Message ID,Message Key 和 Tag 来对消息的消费位点进行重置。