您可通过重置消费位点,按需清除堆积的或不想消费的这部分消息再从最新位点开始消费,或直接跳转到某个时间点消费该时间点之后的消息。
重要
广播消费模式不支持重置消费位点。 目前不支持指定 Message ID、Message Key 和 Tag 来重置消息的消费位点。
操作步骤
登录 SOFAStack 控制台。
在左侧导航栏,选择 中间件 > 消息队列 > Group 管理。
单击目标 Group ID 操作列的 重置消费位点,然后在 重置消费位点 对话框配置以下信息:
Topic:选择重置消费位点针对的 Topic。
重置类型:
清除所有堆积消息,从最新位点开始消费:若选择此项,该 Group ID 在消费该 Topic 下的消息时会跳过当前堆积(未被消费)的所有消息,从这之后发送的最新消息开始消费。
按时间点进行消费位点重置:选择该类型后,您需要选择一个重置时间点,这个时间点之后发送的消息才会被消费。
单击 确定。
单元化说明
在 LDC 单元化架构环境中,进行重置消费位点操作时,需要选择重置消费位点的具体单元,如下图所示。
文档内容是否对您有帮助?