上云无忧 > 文档中心 > 天翼云分布式消息服务消费重置
分布式消息服务
天翼云分布式消息服务消费重置

文档简介:
如果想跳过某些未消费的消息,或者想重新消费队列中的已消费的消息,或者只想消费某个时间点之后的消息(这些消息不论之前是否消费过),那么可以通过“消费重置”功能实现选择性跳过或者重新消费。
*产品来源:中国电信天翼云。免费试用 咨询热线:400-826-7010,为您提供专业的售前咨询,让您快速了解云产品,助您轻松上云! 微信咨询
  免费试用、价格特惠

适用于杭州/南昌/青岛/福州/上海4/北京2/西安2/苏州/广州4/深圳节点


操作场景

如果想跳过某些未消费的消息,或者想重新消费队列中的已消费的消息,或者只想消费某个时间点之后的消息(这些消息不论之前是否消费过),那么可以通过“消费重置”功能实现选择性跳过或者重新消费。

消费重置支持以下三种场景:

消费位置重置到最前:

重新消费队列中的所有的消息,不论之前是否已消费过。

消费位置重置到最后:

跳过队列中当前所有的消息,只消费“重置”之后新生产的消息。

自定义重置位置:

只消费队列中某一时间点之后的消息。

 说明:

如果执行了消费重置,则重置位置之前的消息都变成已消费消息数,不管重置之前是否已消费。

前提条件

已创建队列和消费组,且消费组已消费消息。


操作步骤

步骤 1登录管理控制台。

步骤 2单击页面上方的“服务列表”,选择“应用服务 > 分布式消息服务”,进入分布式消息服务信息页面。

步骤 3单击左侧菜单栏的“队列管理”,进入“队列管理”页面。

步骤 4单击指定队列的名称,显示队列详情。

步骤 5选择“消费组”,显示消费组列表。

步骤 6单击消费组后的“更多”,选择“消费重置”,进入“消费重置”页面。

步骤 7选择“重置位置”、是否强制重置,单击“确定”,执行重置消费位置。


消费消息参数说明

参数

说明

重置位置

l    从队列头端消费消息:重置成功后,该消费组从队列的最头端开始消费。

l    自定义时间消费消息:重置成功后,该消费组只能消费重置时间点之后的消息。

l    从队列尾端消费消息:重置成功后,该消费组只能消费队列中新生产的消息。

默认为从队列头端消费消息。

自定义时间

当重置位置选择“自定义时间消费消息”时,需要设置自定义时间,并且只能选选择72小时范围内的时间。

强制重置

关闭:重置时如果消费组正在消费消息,则重置会失败。

打开:强制进行消费重置,如果消费组正在消费消息,则可能会消费失败。

默认为关闭。

相似文档
  • 步骤 1登录管理控制台。 步骤 2单击页面上方的“服务列表”,选择“应用服务 > 分布式消息服务”,进入分布式消息服务信息页面。 步骤 3单击左侧菜单栏的“队列管理”,进入“队列管理”页面。 步骤 4单击指定队列的名称,显示队列详情。 步骤 5选择“策略管理”,显示策略列表。 步骤 6单击“新增队列策略”,显示“新增队列策略”页面。 步骤 7配置访问策略。
  • Q:分布式消息服务是否提供对消息的先入先出(FIFO)访问? A:支持。DMS创建队列时,可以选择“普通队列”和“有序队列”。有序队列适用于对顺序要求较高的场景,严格按照接收消息的顺序消费消息;普通队列适用于需要高并发度的场景,由于采用分布式设计,不能保证完全按照接收消息的顺序消费消息。
  • 天翼云分布式消息服务用户使用指南.pdf 天翼云分布式消息服务API接口技术规范.pdf
  • 《天翼云分布式消息服务协议》由用户(“甲方”)与中国电信股份有限公司云计算分公司(“乙方”)共同签订。乙方按照本协议的约定,通过乙方官网平台(网址:www.ctyun.cn)向甲方提供天翼云分布式消息服务。甲方应当按照本协议约定使用本服务。
  • 广播消息 在同一个消费组内对所有消费者投递相同消息。 事务消息 支持事务消息,可用于分布式应用 定时消息 支持消息延迟发送。解决开源 RabbitMQ 无延时队列的痛
官方微信
联系客服
400-826-7010
7x24小时客服热线
分享
  • QQ好友
  • QQ空间
  • 微信
  • 微博
返回顶部