重置消费位点

更新时间: 2023-07-26 16:13:14

您可通过重置消费位点,按需清除堆积的或不想消费的这部分消息再从最新位点开始消费,或直接跳转到某个时间点消费该时间点之后的消息。

重要

广播消费模式不支持重置消费位点。 目前不支持指定 Message ID、Message Key 和 Tag 来重置消息的消费位点。

操作步骤

  1. 登录 SOFAStack 控制台

  2. 在左侧导航栏,选择 中间件 > 消息队列 > Group 管理

  3. 单击目标 Group ID 操作列的 重置消费位点,然后在 重置消费位点 对话框配置以下信息:

    • Topic:选择重置消费位点针对的 Topic。

    • 重置类型

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

      • 按时间点进行消费位点重置:选择该类型后,您需要选择一个重置时间点,这个时间点之后发送的消息才会被消费。

  4. 单击 确定

单元化说明

在 LDC 单元化架构环境中,进行重置消费位点操作时,需要选择重置消费位点的具体单元,如下图所示。

选择单元
上一篇: 查看消费者状态 下一篇: 消息查询
阿里云首页 金融分布式架构 相关技术圈