作为Output接入
云消息队列 Kafka 版 可以作为Output接入Logstash。本文说明如何在公网环境下通过Logstash向 云消息队列 Kafka 版 发送消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
企业铂金版计费说明
企业铂金版实例的相关操作，包括创建实例、实例升降配、实例续费以及实例退订，请参见 企业铂金版生命周期管理。云消息队列 RocketMQ 版 支持企业铂金版和标准版实例互相转换，更多信息，请参见 企业铂金版和标准版实例相互转换。
队列（MessageQueue）
队列的主要作用如下：存储顺序性 队列天然具备顺序性，即消息按照进入队列的顺序写入存储，同一队列间的消息天然存在顺序关系，队列头部为最早写入的消息，队列尾部为最新写入的消息。消息在队列中的位置和消息之间的顺序通过位点（Offset...
消费进度管理
云消息队列 RocketMQ 版 通过消费位点管理消费进度，本文为您介绍 云消息队列 RocketMQ 版 的消费进度管理机制。背景信息 云消息队列 RocketMQ 版 的生产者和消费者在进行消息收发时，必然会涉及以下场景，消息先生产后订阅或先订阅后生产...
CreateInstance-创建实例
创建云消息队列 RocketMQ 版5.x系列实例。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险...
订阅关系（Subscription）
本文介绍 云消息队列 RocketMQ 版 中订阅关系（Subscription）的定义、模型关系、内部属性及使用建议。定义 订阅关系是 云消息队列 RocketMQ 版 系统中消费者获取消息、处理消息的规则和状态配置。订阅关系由消费者分组动态注册到服务端...
CA证书管理
云消息队列 MQTT 版 支持使用设备证书进行客户端的接入认证，CA证书可用于签发设备证书、服务器证书和验证证书，客户端使用设备证书进行认证时，服务端将使用设备证书关联的CA证书来验证设备证书是否正确，CA证书必须在 云消息队列 MQTT 版...
步骤一：（可选）RAM用户授权
RAM用户默认没有 云消息队列 RocketMQ 版 资源的操作权限。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或OpenAPI管理 云消息队列 RocketMQ 版 的资源。背景信息 本操作仅针对RAM用户，若您的账号为阿里云账号，则默认...
实例生命周期管理
本文介绍 云消息队列 Kafka 版 实例的控制台操作说明及生命周期管理过程，生命周期包括部署、释放、恢复实例等。控制台操作说明 云消息队列 Kafka 版 实例 操作 列的可操作性说明如下：操作不显示：不可操作。操作置灰：当前状态下不可操作...
UpdateInstance-更新实例
更新云消息队列 RocketMQ 版实例的基本信息和规格配置。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致...
TagResources-为资源绑定标签
接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。本接口一般在需要对云消息队列 RocketMQ ...
OnsTopicDelete-删除Topic
接口说明 注意-阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。删除 Topic 将导致该 Topic 下所有的发布...
OnsGroupDelete-删除Group
接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。删除 Group 后，由 Group ID 标识的消费...
快速使用MQTT.fx模拟SDK收发消息
权限策略名称 说明 AliyunMQFullAccess 管理 云消息队列 MQTT 版 的权限，等同于阿里云账号的权限，被授予该权限的RAM用户具有所有消息收发权限且有控制台所有功能操作权限。AliyunMQPubOnlyAccess 云消息队列 MQTT 版 的发布权限，被授予...
DeleteInstance-删除实例
删除云消息队列 RocketMQ 版实例。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。实例...
OnsTopicCreate-创建Topic
接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。本接口一般是在发布新应用或业务扩展等...
OnsMessageTrace-查看消息消费结果
接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。本接口一般在消费异常，需要判断消息消费...
UntagResources-为资源解绑并删除标签
调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action 元素中使用，用来给RAM用户或RAM角色授予调用此API的权限。具体说明如下：操作：是指具体的权限点。访问级别：是指每个操作的访问级别，取值为写入（Write）、读取...
OnsGroupCreate-创建客户端Group ID
接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。本接口一般是在发布新应用、业务逻辑实现...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的社区版Java SDK收发顺序消息的示例代码供您参考。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，...
资源包说明
云消息队列 RocketMQ 版 的标准版实例按照按量付费方式对API请求资源和Topic资源进行计费，针对这两个计费项，云消息队列 RocketMQ 版 分别推出API请求次数和Topic次数资源包，帮助您以更优惠的价格享受等量资源。使用的资源在资源包规格内...
StartInstance-部署实例
如需使用云消息队列 Kafka 版收发消息，需要购买并部署才可使用，本文介绍如何调用StartInstance部署实例。接口说明 说明 单用户请求频率限制为 2 QPS。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后...
OnsGroupSubDetail-查看Group ID的订阅信息
接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。调试 您可以在OpenAPI Explorer中直接...
集成概述
主要能力是将各类数据流入至 云消息队列 Kafka 版，并且可靠地管理来自不同源头的数据源，同时对来源数据进行筛选和过滤。概念介绍—消息流出（Sink）消息流出的主要能力是将 云消息队列 Kafka 版 的数据流出到各类数据目标，Connector生态...
OnsTrendTopicInputTps-统计消息生产数据
接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。您可以使用本接口获取在线上环境统计的 ...
OnsTraceQueryByMsgKey-根据Message Key创建轨迹查询...
接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。调试 您可以在OpenAPI Explorer中直接...
功能特性
Kafka商业模式 功能集 功能 功能描述 参考文档 Serverless版本 升降配管理 在云消息队列 Kafka 版控制台完成实例升配或降配，配置项包括规格类型、实例类型、发送能力预留和订阅能力预留等。升级实例配置 降低实例配置 弹性策略 V3系列...
开通消息队列服务并授权
在阿里云官方网站开通消息队列服务后方可开始使用 云消息队列 RocketMQ 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的 云消息队列 RocketMQ 版 资源，并使用资源通过SDK收发消息。前提条件 您已注册...
开通消息队列服务并授权
在阿里云官方网站开通消息队列服务后方可开始使用 云消息队列 RocketMQ 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的 云消息队列 RocketMQ 版 资源，并使用资源通过SDK收发消息。前提条件 您已注册...
Topic使用变更
云消息队列 MQTT 版 从V2.x.x升级至V3.x.x后，实现了独立存储，Topic资源不再依赖于 云消息队列 RocketMQ 版，因此两个产品的Topic将完全彼此独立。本文介绍两个版本中Topic资源控制台操作的差异并提供相应控制台截图进行对比。变更说明 ...
MQTT与RocketMQ的消息结构映射
本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景，提供交互中所涉及的消息结构和属性字段的映射关系，方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品，可通过数据互通...
Token鉴权概述
云消息队列 MQTT 版 通过Token鉴权模式向MQTT客户端提供临时访问权限。您可通过MQTT Token服务来给本地账号系统管理的用户颁发临时的访问凭证，并限制访问权限，以实现对单一客户端、单一资源的细粒度权限控制。本文介绍使用流程以及相关...
Token鉴权概述
云消息队列 MQTT 版 通过Token鉴权模式向MQTT客户端提供临时访问权限。您可通过MQTT Token服务来给本地账号系统管理的用户颁发临时的访问凭证，并限制访问权限，以实现对单一客户端、单一资源的细粒度权限控制。本文介绍使用流程以及相关...
查看任务执行记录
在某个实例下发起重启类任务（包括配置变更、版本升级、开启ACL、实例升配）后，您可以在 云消息队列 Kafka 版 控制台查看重启类任务的执行记录，帮助您跟踪任务进展、定位服务端异常重启原因等。前提条件 创建并部署 云消息队列 Kafka 版 ...
发布者最佳实践
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future...
基于日志服务的日志说明
云消息队列 RabbitMQ 版 的日志管理功能将 云消息队列 RabbitMQ 版 实例的消息操作日志推送到日志服务，通过SLS分析语句快速查询并统计TPS流量图表。本文介绍SLS中日志字段和请求方法。字段说明 查询的日志字段说明如下表所示。表 1.日志...
生产者负载均衡
生产者发送消息到 云消息队列 RocketMQ 版 服务端时，云消息队列 RocketMQ 版 将根据生产者负载均衡策略将消息均匀的存储在多个队列中，避免产生热点队列和性能瓶颈。本文介绍 云消息队列 RocketMQ 版 生产者的负载均衡策略。背景信息 了解...
设备证书管理
本文介绍如何使用CA证书签发设备证书，并在 云消息队列 MQTT 版 控制台管理设备证书，包括查询证书、下载证书、激活或注销证书以及删除证书。背景信息 设备证书是由CA根证书签发给客户端设备使用的数字证书，用于客户端和服务端连接时，...
为什么Group管理页面的Group变多了？
问题现象 在 云消息队列 Kafka 版 控制台 的 Group 管理 页面查看您Kafka集群上所有存在的Group时，显示的Group数量多于您手动创建的数量。可能原因 若Group的 自动创建 栏为 否，说明此Group创建于 云消息队列 Kafka 版 控制台 的 Group ...
主题（Topic）
本文介绍 云消息队列 RocketMQ 版 中主题（Topic）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 主题是 云消息队列 RocketMQ 版 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题的作用主要如下：...
- 产品推荐
- 这些文档可能帮助您