消费延迟监控 通道服务通过 DescribeTunnel API 提供了客户端消费数据延迟（即当前消费到的数据的时间点）信息，并在控制台提供了通道数据消费监控。数据消费能力水平扩展 通道服务提供了逻辑分区的自动负载均衡功能，负载均衡增加了消费端...
RFM用户类型 RS FS MS 说明 高价值客户 大于等于RS对比值 大于等于FS对比值 大于等于MS对比值 将最近消费日期较近、消费频次较高、消费金额较高的人群定义为高价值人群。重点保持客户 小于RS对比值 大于等于FS对比值 大于等于MS对比值 将...
RFM用户类型 RS FS MS 说明 高价值用户 大于等于RS对比值 大于等于FS对比值 大于等于MS对比值 将最近消费日期较近、消费频次较高、消费金额较高的用户定义为高价值用户。重点保持用户 小于RS对比值 大于等于FS对比值 大于等于MS对比值 将...
为了防止消息重复消费导致业务处理异常，轻量消息队列（原 MNS）的消费者在接收到消息后，需要根据业务唯一标识对消息做幂等处理。本文介绍消费幂等的概念、适用场景以及处理方法。什么是消费幂等 在消息队列场景中，消费幂等处理是指即使...
每个承诺消费周期可抵扣的最大流量处理费金额=承诺消费金额÷节省计划折扣 节省计划总金额=承诺消费金额×购买时长下包含的承诺消费周期个数 其中购买时长包含的承诺消费周期个数可通过计算得出，假设购买节省计划时您指定的承诺消费周期为...
消费位点（ConsumerOffset）一条消息被某个消费者消费完成后不会立即从队列中删除，云消息队列 RocketMQ 版 会基于每个消费者分组记录消费过的最新一条消息的位点，即消费位点。更多信息，请参见 消费进度管理。消息索引（MessageKey）消息...
日志服务控制台提供消费预览功能，帮助您通过控制台直接预览Logstore中的部分日志数据。消费预览也是一种日志消费。本文为您介绍消费预览具体步骤。前提条件 已完成日志消费，更多消费方式，请参见：普通消费概述。操作步骤 登录 日志服务...
AI 网关支持为MCP服务和MCP工具配置消费者认证。通过API key的认证方式验证调用者的身份，精准控制 API 访问权限，实现多租户细粒度管控，保障敏感数据隔离与合规调用，有效防止未授权访问和资源滥用。本文为您介绍如何配置消费者认证。...
在 消费者 区域单击 授权，在消费者下拉框中选择消费者，您也可以单击 创建消费者 为新的消费者进行授权。最后单击 添加。相关文档 如何创建消费者、授权消费者。具体详情，请参见 创建消费者、授权管理。消费者如何通过认证和鉴权实现安全...
什么是Kafka消息堆积 Kafka消息堆积是指：消费者未能及时消费生产者写入的消息，导致未被消费的消息在分区中“积压”。消息堆积总量=最大位点（全部分区）-消费位点（全部分区）消息堆积总量越大，堆积越严重。消息堆积总量趋近于0表示消费...
每次重试的间隔时间如下：第几次重试 每次重试间隔时间 1 10 秒 2 30 秒 3 1 分钟 4 2 分钟 5 3 分钟 6 4 分钟 7 5 分钟 8 6 分钟 9 7 分钟 10 8 分钟 11 9 分钟 12 10 分钟 13 20 分钟 14 30 分钟 15 1 小时 16 2 小时 广播消费方式 广播...
云原生API网关通过消费者来为路由、API开启认证能力，本文介绍云原生API网关控制台如何管理消费者。创建消费者 云原生API网关为您提供了三种认证方式。配置方式 说明 场景适用 API Key 客户端需将凭证按指定方式添加到请求中，网关验证其...
背景信息 关于消费组的介绍请参见 消费组。操作步骤 进入目标地域的订阅任务的列表页面（二选一）。通过DTS控制台进入 登录 数据传输服务DTS控制台。在左侧导航栏，单击 数据订阅。在页面左上角，选择订阅实例所属地域。通过DMS控制台进入 ...
查询消费组 CreateConsumerGroup-创建消费组 DeleteConsumerGroup-删除消费组 UpdateConsumerGroup-更新消费者组 GetCheckPoint-获取指定消费组的消费点 ConsumerGroupUpdateCheckPoint-更新消费进度 ConsumerGroupHeartBeat-消费者发送...
例如一个消费者的Prefetch Count参数为100条，每条消息需要30秒，则处理完这一批消息需要3000秒，而最长消费时间只有300秒，这样每个消费者只有前10条消息能够被正常消费，后续所有消息都将消费失败，消息将出现堆积。解决办法 通过如下...
使用服务端订阅 管理消费组 消费组是消息消费端的身份标识，多个消费者组成消息消费组接入物联网平台。设置服务端订阅后，物联网平台会将收到的设备消息转发到相应消费组，每条被流转到消费组的消息会被其中一个消费者接收。本文介绍如何在...
本文主要介绍 云消息队列 RabbitMQ 版 的顺序消费实现原理，与开源RabbitMQ的不同之处，以及其配置方式和使用限制。顺序消费实现原理 RabbitMQ的顺序消费需要“顺序存储”和“单一消费者”两个条件同时满足才能实现。开源 RabbitMQ 实现 ...
本文介绍 云消息队列 RabbitMQ 版 服务端默认的消费重试策略，帮助您理解消费失败后的消息处理逻辑，并选择合适的消息处理策略。消费重试流程 消费重试机制通过在临时性故障发生时自动重新尝试发送或处理消息，提升系统的可靠性和数据一致...
消费提交 消费者完成消费处理，并向服务端提交消费结果，服务端标记当前消息已经被处理（包括消费成功和失败）。云消息队列 RocketMQ 版 默认支持保留所有消息，此时消息数据并不会立即被删除，只是逻辑标记已消费。消息在保存时间到期或...
如需提高消息的处理效率，或降低下游资源的API调用频率，您可使用批量消费功能。本文介绍批量消费的定义、优势与场景、使用限制和示例代码等信息。什么是批量消费 定义 批量消费是 云消息队列 RocketMQ 版 通过Push消费者提供的、将消息分...
行为约束 消费模式为CLUSTERING时 当消费模式为CLUSTERING时，同一个ConsumerGroup下的每个消费者的订阅关系、消费逻辑需要保持一致，否则会出现消费冲突，导致部分消息消费异常。正确示例/Consumer c1 Consumer c1=ConsumerBuilder.build...
客户端消费流程 了解客户端消费流程，有助于理解消息是否堆积。一般情况下，客户端消费流程大致如下：判断消息堆积是否属于正常情况 如果发现Group中出现消息堆积，请参见下列步骤，判断消息堆积是否属于正常情况：登录 云消息队列 Kafka ...
说明 消费位点保留时长 是消费位点的最大保留时长，从提交消费位点的时间开始计算，超过该时长的消费位点将被删除（注意，删除消费位点并非消费位点置为0，而是无消费位点）。每向一个Topic分区提交一次消费位点，该消费位点的保留时间计时...
在 云消息队列 RabbitMQ 版 中，消费重复（Message Duplication）指的是消费者在消费消息时，可能会多次接收到同一条消息。本文为您介绍消费重复的可能原因及解决办法。可能原因 消费重复可能由以下原因导致：消息重推特性导致：云消息队列...
当消费者出现故障或者消费错误数据时，您可通过重置消费位点将消费位置回滚到之前的某个位点重新开始消费，您也可以将消费位置移动至最新位点，暂时不处理堆积的消息。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的...
消息堆积 Message accumulation Producer 已经将消息发送到消息队列的服务端，但由于 Consumer 消费能力有限，未能在短时间内将所有消息正确消费掉，此时在消息队列的服务端保存着未被消费的消息，该状态即消息堆积。消息过滤 Message ...
在 消费者 区域单击 授权，在消费者下拉框中选择消费者，您也可以单击 管理消费者 为新的消费者进行授权。最后单击 添加。相关文档 如何创建消费者、授权消费者。具体详情，请参见 管理消费者、授权管理。消费者如何通过认证和鉴权实现安全...
在 消费者 区域单击 授权，在消费者下拉框中选择消费者，您也可以单击 管理消费者 为新的消费者进行授权。最后单击 添加。相关文档 如何创建消费者、授权消费者。具体详情，请参见 管理消费者、授权管理。消费者如何通过认证和鉴权实现安全...
应用系统可作为元数据采集的数据来源，也可同步开启消费功能以对接Quick BI自助消费。本文为您介绍如何创建及管理应用系统。前提条件 仅支持V5.5.1及以上版本、独立部署环境的Quick BI应用系统。需购买资产消费功能才能配置消费相关配置。...
设置消费限制后，若您的消费未达到每日消费上限，ARMS将持续监控您的应用；若您的消费达到每日消费上限，ARMS将停止监控您的应用并且停止计费，次日00:00自动开启监控并且开始计费。在 ARMS控制台 左侧导航栏中选择 前端监控 前端列表。在 ...
RFM模型是一种通过用户的R消费间隔（Recency）、F消费频率（Frequency）、M消费金额（Monetary）三项指标来衡量用户价值的手段。RFM模型对用户的三项指标的值分别进行量化评分，评分标准例如：R：依据最近一次消费距今天数，0~30：3分，31~...
消费位点提交频率 重要 尽快修复 消费客户端每秒提交xx次消费位点 消费客户端过于频繁提交消费位点，会影响集群整体性能和稳定性，建议改为自动提交消费位点的方式，或者降低提交消费位点的频率。下面展示了提交位点频率前十的Group信息，...
云消息队列 RocketMQ 版 的消息负载均衡策略针对生产者和消费者有所差异。对消费者而言，消息负载均衡策略在一定程度上影响消息堆积。背景信息 随着SDK版本的升级，云消息队列 RocketMQ 版 的负载均衡策略也有所优化，根据SDK版本，负载...
应用场景 异步解耦消息队列的生产消费模型可以解耦上下游业务系统，并支持下游多个消费者对同一消息进行消费和处理。以金融场景为例，支付中心作为支付宝主站最核心的系统，每笔支付数据的产生会引起几百个下游业务系统的关注，包括账户...
名称 类型 描述 示例值 object 消费组数据结构。name string 消费组名称。test-consumer-group timeout integer 超时时间。在超时时间段内没有收到心跳，消费者将被删除。单位：秒。300 order boolean 是否按顺序消费。true：在 Shard 中按...
本文介绍如何停用或删除AI 网关消费者。停用消费者 登录 AI网关控制台。在左侧导航栏，选择 消费者，并在顶部菜单栏选择地域。在 消费者 列表页面，单击目标消费者的 操作 列下的 停用，然后在确认停用对话框中单击 确定。删除消费者 登录 ...
消费者本地等待耗时：统计Group消费消息时，消息到达消费者客户端到开始被消费的耗时。消费客户端访问协议占比：统计所有被消费的消息各协议类型消息量的占比。实例 Top 20概览 已就绪消息排队时间 top20 GroupIDs：统计已就绪消息排队时间...
消费订阅数据 根据消费客户端和数据库的类型，选择订阅数据的消费方式：使用SDK示例代码消费订阅数据 使用SDK示例代码消费PolarDB-X 1.0订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据 结束数据订阅 释放实例...
为了防止消息重复消费导致业务处理异常，SOFAStack 消息队列的消费者在接收到消息后，有必要根据业务上的唯一 Key 对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...
消费者本地等待耗时：统计Group消费消息时，消息到达消费者客户端到开始被消费的耗时。消费客户端访问协议占比：统计所有被消费的消息各协议类型消息量的占比。实例 Top 20概览 已就绪消息排队时间 top20 GroupIDs：统计已就绪消息排队时间...