配置AMQP服务端订阅
如果需要所有消费者收到消息，当消费者数量较少时，可以为每个消费者单独创建一个消费组，当消费者数量较多时，可以使用云产品流转将消息 转发到消息队列RocketMQ，然后 使用广播消费。前提条件 已创建产品。已创建消费组。您可使用物联网...
死信队列
当一条消息初次消费失败，消息队列会自动进行消息重试。达到最大重试次数后，若消费依然失败，则表明消费者在正常情况下无法正确地消费该消息。此时，消息队列不会立刻将消息丢弃，而是将其发送到该消费者对应的特殊队列中。在消息队列中，...
为什么分区消费时间相差较大、滞后明显或乱序？
同一个 Group 的所有消费端实例，分区消费时间相差较大、滞后明显或乱序。现象 在 云消息队列 Kafka 版 控制台 的 Group 管理 页面，找到目标Group，在其 操作 列，选择 更多>消费状态。在 Group 详情 的 消费状态 页签，显示该Group订阅的...
CreateConsumerGroup
调用CreateConsumerGroup接口在指定的Logstore上创建一个消费组。接口说明 请求语法中Host由Project名称和日志服务Endpoint构成，您需要在Host中指定Project。每个Logstore中最多创建30个消费组。消费组名称，在Project下必须唯一。已创建...
定时/延时消息
消费提交 消费者完成消费处理，并向服务端提交消费结果，服务端标记当前消息已经被处理（包括消费成功和失败）。云消息队列 RocketMQ 版 默认支持保留所有消息，此时消息数据并不会立即被删除，只是逻辑标记已消费。消息在保存时间到期或...
旧版订阅迁移至新版订阅
创建消费组进行消费，详情请参见 新增消费组。消费时间点的管理 整个订阅实例使用一份位点数据。可以在DTS控制台修改消费的时间。每个消费组单独使用一份位点数据。新版订阅的位点管理比较灵活和多样，SDK客户端重启时，SUBSCRIBE模式使用...
查询消息轨迹
消息轨迹是指一条消息从生产者发送到消息队列服务端，再到消费者消费处理，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。本文介绍如何快速查询消息轨迹。前提条件 您的消息已从生产者发送。操作步骤 登录 SOFAStack...
使用Java实现Kafka消费
在这个时间间隔内加入组的消费者为消费组的成员，进行分区分配，各个消费者按分配的分区开发消费数据，如果在这个时间内还有消费者没有加入消费组，则会触发消费组再平衡操作，再平衡期间不会消费数据，会导致消费延迟。建议设置max.poll....
配置消费者鉴权
云原生网关支持为路由配置认证，并对指定的消费者进行鉴权，以允许对应消费者访问路由。本文介绍如何配置消费者鉴权。背景信息 相比全局认证鉴权适用于统一登录认证等ToC场景，路由认证和消费者鉴权模式适用于授权API给合作伙伴等ToB场景。...
QueryConsumerGroupStatus
使用AMQP服务端订阅时，调用该接口查询某个消费组的状态，包括在线客户端信息、消息消费速率、消息堆积数、最近消息消费时间。QPS限制 单个阿里云账号调用该接口的每秒请求数（QPS）最大限制为5。说明 RAM用户共享阿里云账号配额。调试 您...
在用户中心如何查询消费记录
概述 本文主要介绍在用户中心如何查询消费记录。详细信息 进入管理控制台 用户中心，单击左侧导航栏中的月账单概览，您可查询到此阿里云账号的各月消费总览，以及各产品消费总计。如您需要查询消费明细，请单击左侧导航栏中账单详情。在...
排查订阅任务问题
背景信息 由于订阅任务没有使用SDK进行消费订阅数据、对SDK进行过较多修改以及订阅客户端运行环境的不同，导致排查订阅任务问题比较困难。在此提供一个工具包，在客户端的环境执行后可以协助定位和排除DTS的问题。重要 使用该工具包会更新...
服务端订阅使用限制
失败推送重试策略 由于消费客户端离线、消息消费慢等原因，消息不能实时消费，而进入堆积队列。消费客户端重新上线并恢复稳定消费能力后，物联网平台重试推送堆积消息。如果客户端对重试推送的消息消费失败，可能导致堆积队列阻塞。按大约...
趣店
消费金融互联网渠道的需求：客户希望有效整合线上线下资源，将对互联网的认知从渠道、入口转变到平台思维，围绕移动端、桌面端、实体经营场所消费场景等各个方面构建全方位服务和沟通媒介，整合线上线下资源。消费金融行业发展：随着金融...
使用Kafka客户端消费订阅数据
新版数据订阅支持使用0.11版本至2.7版本的Kafka客户端消费订阅数据，DTS为您提供了Kafka客户端Demo，本文将介绍该客户端的使用说明。注意事项 使用本文提供的Demo消费数据时，如果采用auto commit（自动提交），可能会因为数据还没被消费完...
接口和参数说明
表 2.Push方式特有参数（批量消费）参数 说明 ConsumeMessageBatchMaxSize 批量消费的最大消息数量，缓存的消息数量达到设置的参数值，云消息队列 RocketMQ 版 会将缓存的消息统一推送给消费者进行批量消费。默认值：32，取值范围：1~1024...
功能特性
集群消费和广播消费：当使用集群消费模式时，消息队列认为任意一条消息只需要被消费者集群内的任意一个消费者处理即可；当使用广播消费模式时，消息队列会将每条消息推送给消费者集群内所有注册过的消费者，保证消息至少被每台机器消费一次...
表操作篇
例如，存储消费记录表，近期产生的消费记录被访问的可能性较大，因为应用程序需要及时地对消费记录进行处理和统计，或者查询最近的消费记录。但是年代久远的消费记录被查询的可能性不大，这些数据渐渐成为冷数据，但仍然占用存储空间。其次...
功能与特性概述
集群消费和广播消费：当使用集群消费模式时，云消息队列 RocketMQ 版 认为任意一条消息只需要被消费者集群内的任意一个消费者处理即可；当使用广播消费模式时，云消息队列 RocketMQ 版 会将每条消息推送给消费者集群内所有注册过的消费者，...
欠票冲抵
说明 阿里云是基于客户实际消费金额开具发票，如果您对已经开具发票的资源订单，再操作退款，降配等操作，则实际消费的金额少于您已经开具的发票金额，其中的差额部分即产生为欠票。举例：客户A在1号下单购买ECS云服务器资源，支付100元，...
购买和使用节省计划
您可以根据企业版转发路由器处理的流量字节数计算承诺消费金额然后购买节省计划。本文介绍如何计算承诺消费金额、购买节省计划以及查看节省计划的使用效果。计算承诺消费金额 转发路由器节省计划适用于有稳定流量、流量峰值波动不大、资源...
使用Confluent-Kafka-Go实现Kafka消费
在这个时间间隔内加入组的消费者为消费组的成员，进行分区分配，各个消费者按分配的分区开发消费数据，如果在这个时间内还有消费者没有加入消费组，则会触发消费组再平衡操作，再平衡期间不会消费数据，会导致消费延迟。建议设置max.poll....
删除Group后仍然收到消息堆积的告警信息
解决方案 删除 Group 后，如果您不希望继续收到消息堆积的告警信息，请参见以下操作进行处理：确认服务端版本，请根据服务端版本情况执行以下操作：2.2.0及以上版本，请根据以下方式操作：若 Group 中没有存活的消费者线程（存活的消费者...
查询账单
消费类型说明 账单中存在两种消费类型，下表列出两种消费类型包含的具体费用，详细的费用说明，请参见 产品计费。消费类型 具体费用 后付费 使用企业版 V1和企业版 V0时，收取SQL洞察和审计的存储费用。使用企业版 V2时，收取：SQL洞察和...
查看消费明细
如果您对 云消息队列 Kafka 版 服务的消费情况产生疑问，可以查看消费明细。查看费用账单 登录 云消息队列 Kafka 版 控制台。在页面右上角，选择 费用>用户中心。在左侧导航栏，按需选择 账单管理 目录下的账单维度，查看您的消费信息。月...
从Kafka同步数据
Kafka消费表只是用来消费Kafka数据，没有真正地存储数据，最终消费数据需要实现消息批处理后进行消费。建表语法如下。CREATE TABLE[IF NOT EXISTS][db.]table_name[ON CLUSTER cluster](name1[type1][DEFAULT|MATERIALIZED|ALIAS expr1],...
使用Kafka客户端消费订阅数据
新版数据订阅支持使用0.11版本至2.7版本的Kafka客户端消费订阅数据，DTS为您提供了Kafka客户端Demo，本文将介绍该客户端的使用说明。注意事项 使用本文提供的Demo消费数据时，如果采用auto commit（自动提交），可能会因为数据还没被消费完...
OnsConsumerAccumulate-查询消息消费堆积情况
查询指定Group ID的消息消费堆积情况，包括当前消息堆积数量和消费延迟时间等。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 Open...
消息轨迹
消费者 本次消费结果 消息某次消费的消费结果。取值如下：消费成功 消费失败 未返回应答 消费者信息 消费者订阅消息时使用的RocketMQ账号或AccessKey ID。主机名 消费者客户端所在机器的主机名。是否顺序投递 消费者所属的消费者分组是否...
顺序消息
顺序消息可以保证消息的消费顺序和发送的顺序一致，即先发送的先消费，后发送的后消费，常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...
Group管理
重置消费位点：通过重置消费位点，按需清除堆积的或不想消费的这部分消息再开始消费，或直接跳转到某个时间点消费该时间点之后的消息（不论是否消费过该时间点之前的消息）。更多信息，请参见 重置消费位点。云监控：查看当前Group下的消息...
实例规格配置和管理
您可以按照业务需求调整流量规格、网络类型、消息保留时长、最大消息大小和消费位点保留时间。前提条件 您已购买 云消息队列 Kafka 版 V3系列Serverless实例，且实例处于 服务中 状态。规格配置说明 配置项 含义 变更方式 流量规格 发送...
ConsumerGroupHeartBeat-消费者发送心跳到服务端
消费者发送心跳到服务端 接口说明 消费者和服务端通过固定时间发送心跳建立连接。在固定时间段内没有收到心跳，消费者将被删除。Host 由 Project 名称和日志服务 Endpoint 构成，您需要在 Host 中指定 Project。调试 您可以在OpenAPI ...
服务提供方或消费方流控
AHAS 应用防护可以根据服务提供方的能力和服务消费方的分配能力进行流量控制。其中服务提供方（Service Provider）是指对外提供请求的服务或应用；服务消费方（Service Consumer）是指调用该服务的下游应用。根据服务提供方限流 为了保护...
服务提供方或消费方流控
限流降级可以根据服务提供方的能力和服务消费方的分配能力进行流量控制。其中服务提供方（Service Provider）是指对外提供请求的服务或应用；服务消费方（Service Consumer）是指调用该服务的下游应用。根据服务提供方限流 为了保护服务...
消费端挂载NFS是否会影响消费速度？
问题现象 消费端在消费消息的主线程里同步将拉取的消息存储在NFS，导致消费端处理消息的速度变慢，阻塞消息处理。可能原因 NFS本身速度就不太理想。NFS是网络共享存储，虽然有多机器共享访问的能力优势，但多台机器访问是争抢的，消费者...
使用Confluent-Kafka-Python实现Kafka消费
在这个时间间隔内加入组的消费者为消费组的成员，进行分区分配，各个消费者按分配的分区开发消费数据，如果在这个时间内还有消费者没有加入消费组，则会触发消费组再平衡操作，再平衡期间不会消费数据，会导致消费延迟。重要 使用confluent...
错误码
错误码简介 消费端通过CSB调用服务时，整个链路上可以分成三个阶段：服务消费端应用以消费端协议访问CSB。CSB处理转发服务调用请求。CSB以提供端协议访问服务提供端应用。这三个阶段都可能出错，服务消费端收到错误信息时要能区别是在哪个...
消息轨迹
消息轨迹是指一条消息从生产者发送到 云消息队列 RabbitMQ 版 服务端，再到消费者消费，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。如果消息收发不符合预期，您可以通过查询消息轨迹，快速分析和定位问题，及时...
死信队列
对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版 不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...
- 产品推荐
- 这些文档可能帮助您