API概览
当消费者出现故障或者消费错误数据时，您可通过重置消费位点将消费位置回滚到之前的某个位点重新开始消费，您也可以将消费位置移动至最新位点，暂时不处理堆积的消息。ListConsumerGroupSubscriptions 查询消费者组订阅关系列表 查询指定...
重置消费位点
当消费者出现故障或者消费错误数据时，您可通过重置消费位点将消费位置回滚到之前的某个位点或者指定分区位点，重新开始消费。您也可以将消费位置移动至最新位点，暂时不处理堆积的消息。前提条件 已停止所有Consumer客户端（云消息队列 ...
PaaS应用场景
RetailBot会根据消费者问题、上下文、知识库、机器人配置等多个因素，智能计算最优解并返回给开发者，由开发者结合其他服务策略/工具，为消费者提供即时响应。公测MVP版本主要支持的业务场景包括：行业高频场景识别、消费者情绪识别、直连...
仪表盘
最晚一条拉取消息的位点－最晚一条提交消息的位点 已就绪的消息（ready messages）消息在 云消息队列 RocketMQ 版 服务端已就绪，对消费者可见可被消费的消息。最大消息位点－最晚一条拉取消息的位点 消息堆积量（consumer lag）所有未处理...
通过消费组消费数据
创建一个消费组并启动一个消费者线程，该消费者会从指定的Logstore中消费数据。管理消费组的代码示例，请参见 使用Java SDK管理消费组、使用Python SDK管理消费组。import com.aliyun.openservices.loghub.client.ClientWorker;import ...
通过消费组消费数据
创建一个消费组并启动一个消费者线程，该消费者会从指定的Logstore中消费数据。管理消费组的代码示例，请参见 使用Java SDK管理消费组、使用Python SDK管理消费组。import com.aliyun.openservices.loghub.client.ClientWorker;import ...
查看Rebalance详情
消费客户端出现Rebalance可能是以下原因：当消费者主动新增订阅或者取消订阅时，会触发该Consumer Group内的Rebalance。当Topic的分区数量发生变化时，会触发Rebalance。当Consumer Group内的消费者成员数量增加或者减少时，会触发...
消费者（Consumer）
内部属性 消费者分组名称 定义：当前消费者关联的消费者分组名称，消费者必须关联到指定的消费者分组，通过消费者分组获取消费行为。更多信息，请参见 消费者分组（ConsumerGroup）。取值：消费者分组为 云消息队列 RocketMQ 版 的逻辑资源...
应用场景
部分应用有自己的规范，无法按照 AD、钉钉的同步接口要求进行调整，导致账户变更需要在多点重复操作，容易导致错配、漏配问题，且消耗时间精力，是低价值重复劳动。 IDaaS 能作为桥梁，将不同体系中的身份贯通在一起，可以即时将钉钉、AD...
消费者分类
云消息队列 RocketMQ 版 支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息 云消息队列 RocketMQ 版 面向不同的业务场景提供了不同...
队列服务订阅推送
在不同的消费者组间，数据会并列地推送给每一个存在的消费者，举例来看：如果您的多个消费者在同一个组内，您可以观察到数据会在这些消费者之间进行均衡地分发，消费者会收到不同的数据。如果您的多个消费者在多个不同的组内，您可以观察到...
限流降级
降级 在EDAS中，降级通常用于对下游出现超时的非核心服务提供者进行低优先级调用，确保上游核心应用（服务消费者）不被影响。通过在服务消费者端配置降级模块代码，并在EDAS中配置降级策略，使服务消费者具备降级功能。此时服务消费者去...
消费者负载均衡
背景信息 了解消费者负载均衡策略，可以帮助您解决以下问题：消息消费处理的容灾策略：您可以根据消费者负载均衡策略，明确当局部节点出现故障时，消息如何进行消费重试和容灾切换。消息消费的顺序性机制：通过消费者负载均衡策略，您可以...
消费幂等
什么是消息幂等 当出现消费者对某条消息重复消费的情况时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响，那么这个消费者的处理过程就是幂等的。例如，在支付场景下，消费者消费扣款消息，对一笔...
服务提供方或消费方流控
例如，资源Ａ配置了一条针对消费者caller1的规则，那么当且仅当来自消费者caller1对资源A的请求才会触发流量控制。other：表示针对除 {some_origin_name} 以外的其余调用方的流量进行流量控制。这个场景适用于资源对大部分消费者都有一个...
限流降级
降级 在EDAS中，降级通常用于对下游出现超时的非核心服务提供者进行低优先级调用，确保上游核心应用（服务消费者）不被影响。通过在服务消费者端配置降级模块代码，并在EDAS中配置降级策略，使服务消费者具备降级功能。此时服务消费者去...
重置消费位点
重置消费位点功能只能重置对消费者可见的消息，不能重置定时中、重试等待中的消息。重试消费位点只能在消费者在线时进行操作。操作步骤 登录 云消息队列 RocketMQ 版 控制台，在左侧导航栏单击 实例列表。在顶部菜单栏选择地域，如 华东1...
订阅关系（Subscription）
行为约束 订阅关系一致 云消息队列 RocketMQ 版 是按照消费者分组粒度管理订阅关系，因此，同一消费者分组内的消费者在消费逻辑上必须保持一致，否则会出现消费冲突，导致部分消息消费异常。正确示例/Consumer c1 Consumer c1=...
用户洞察概述
随着互联网技术的发展，企业通过各种途径积累了消费者资产，Quick Audience用户洞察模块旨在通过丰富的用户洞察模型和便捷的策略配置，帮助企业完成消费者多维洞察分析，为后续的消费者运营和触达奠定人群基础。功能简介 用户洞察模块提供...
配置同可用区优先路由
在服务消费者调用服务提供者时，如果您的服务提供者是跨可用区部署的，那么您可以为服务提供者开启同可用区优先路由功能。该功能可以优先调用同可用区的服务提供者，从而避免服务之间跨可用区调用导致的网络延迟问题，缩短HTTP响应时间。...
配置消费者鉴权
消费者说明 对消费者进行描述。认证方式 当前消费者支持的认证方式。密钥类型 对称密钥：生成一份默认的JWKS配置（每个消费者不同），包含加密或者解密Token时使用的密钥。非对称密钥：需要您自己填写完整的JWKS配置，使用私钥加密Token。...
消息幂等
什么是消息幂等 当出现消费者对某条消息重复消费的情况时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响，那么这整个过程就实现了消息幂等。例如，在支付场景下，消费者消费扣款消息，对一笔订单...
服务提供方或消费方流控
例如，资源 Ａ 配置了一条针对消费者 caller1 的规则，那么当且仅当来自消费者 caller1 对资源 A 的请求才会触发流量控制。other：表示针对除 {some_origin_name} 以外的其余调用方的流量进行流量控制。这个场景适用于资源对大部分消费者都...
消费者分组（ConsumerGroup）
使用建议 按照业务合理拆分分组 云消息队列 RocketMQ 版 的消费者和主题是多对多的关系，对于消费者分组的拆分设计，建议遵循以下原则：消费者的投递顺序一致：同一消费者分组下所有消费者的消费投递顺序是相同的，统一都是顺序投递或并发...
概述
应用场景 异步解耦消息队列的生产消费模型可以解耦上下游业务系统，并支持下游多个消费者对同一消息进行消费和处理。以金融场景为例，支付中心作为支付宝主站最核心的系统，每笔支付数据的产生会引起几百个下游业务系统的关注，包括账户...
简介
在日志服务中，一个日志库（Logstore）下面会有多个分区（Shard），协同消费库将 shard 分配给一个消费组下面的消费者，分配方式遵循以下原则：每个shard只会分配到一个消费者。一个消费者可以同时拥有多个shard。新的消费者加入一个消费组...
查看消费者状态
就绪消息量 消息在 云消息队列 RocketMQ 版 服务端已就绪，对消费者可见可被消费的消息。排队时间 最早一条就绪消息的就绪时间和当前时刻的时间差。该时间反映消费者拉取消息的及时性。订阅关系 显示该Group ID下消费者实例群组的订阅关系...
如何处理消息堆积
导航栏中选择 消息轨迹，单击 创建查询任务，选择 按 Message ID 查询，输入对应的信息，发现部分消息已发送至Broker节点，但未投递给下游消费者。可能原因 云消息队列 RocketMQ 版 的消息发送至Broker节点后，配置了Group ID的客户端根据...
常见问题
服务消费者调用服务提供者的策略是什么？默认是随机调用，如有更精细的需求，请参见 负载均衡。在 Registry 宕机后，如何避免因为服务提供者不健康而出现调用失败的问题？无论 SOFARegistry 是否宕机，SOFARPC 框架对服务提供者调用失败的...
消费进度管理
云消息队列 RocketMQ 版 重置消费位点功能只能重置对消费者可见的消息，不能重置定时中、重试等待中的消息。更多信息，请参见 定时/延时消息 和 消费重试。版本兼容性 关于消费者分组的消费位点初始值，不同的服务端版本中定义如下：服务端...
死信队列
重新发送死信消息 一条消息进入死信队列，意味着某些因素导致消费者无法正常消费该消息，因此，通常需要您对其进行特殊处理。排查可疑因素并解决问题后，您可以在消息队列控制台重新发送该消息，让消费者重新消费一次。说明 死信消息被重新...
领域模型概述
一对一通信：基于消费匿名特点，下游消费者即使有多个，但都没有自己独立的身份，因此共享队列中的消息，每一条消息都只会被唯一一个消费者处理。因此点对点模型只能实现一对一通信。发布订阅模型 发布订阅模型具有如下特点：消费独立：...
消息过滤
可能原因：若多个消费者是通过同一个消费者分组（Group ID）订阅的指定Topic，则所有消费者的过滤条件即订阅的Tag要一致，否则会出现订阅关系不一致，导致部分消息丢失。消费者设置了过滤条件，消息消费数量是按照过滤前还是过滤后计算呢？...
消费重试
和PushConsumer消费重试策略不同的是，SimpleConsumer消费者的重试间隔是预分配的，每次获取消息，消费者会在调用API时设置一个不可见时间参数 InvisibleDuration，即消息的最大处理时长。若消息消费失败触发重试，不需要设置下一次重试的...
如何排查Java场景下故障注入不生效的问题
在对Java进程注入故障时，可能会出现故障注入失败的情况。为解决此类问题，在创建或编辑演练时，您可以在故障执行阶段选择开启Debug模式，并通过相关的日志信息来了解故障注入失败的原因。开启Debug模式 在查看目标演练的故障注入日志前，...
TCP协议客户端大版本发布
该策略可能会出现以下问题：消费者数量比和Queue数量多时，部分消费者获取不到消息的现象。部分消费者异常或者处理缓慢，其他消费者空闲却无法共同分担堆积压力的情况。以消息为粒度进行负载，负载策略更加均衡。避免了队列级负载策略可能...
无损下线
为什么需要无损下线 由于微服务应用自身调用特点，在高并发下，服务提供端应用实例的直接下线，会导致服务消费端应用实例无法实时感知下游实例的实时状态，因而出现继续将请求转发到已下线的实例，从而出现请求报错，流量有损。无损下线...
集群消费和广播消费
集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...
基本概念
消费位点（ConsumerOffset）一条消息被某个消费者消费完成后不会立即从队列中删除，云消息队列 RocketMQ 版 会基于每个消费者分组记录消费过的最新一条消息的位点，即消费位点。更多信息，请参见 消费进度管理。消息索引（MessageKey）消息...
常见问题
使用云消息队列 Kafka 版时客户端的报错及解决方案 无法ping通云消息队列 Kafka 版的接入点 客户端消费问题 订阅者最佳实践 客户端首次接入云消息队列 Kafka 版时出现异常的排查方法 使用云消息队列 Kafka 版时出现消息堆积 为什么消费客户...
- 产品推荐
- 这些文档可能帮助您