实例管理
删除实例 警告 实例删除后将无法恢复，并且若该实例绑定了云消息队列 MQTT 版服务，会导致绑定的微消息队列MQTT版服务不可用，请谨慎操作。标准版实例需要清空实例下的所有Topic和Group资源后才可删除。删除标准版实例 标准版实例计费方式...
Spring集成
spring.rabbitmq.listener.simple.missing-queues-fatal 如果容器声明的队列在代理上不可用，是否失败；或者如果在运行时删除一个或多个队列，是否停止容器。默认值为true。spring.rabbitmq.listener.simple.idle-event-interval 发布空闲...
YARN调度器
FIFOScheduler：是最简单的调度器，不支持多租户（所有应用都提交到Default队列），不考虑集群的资源分布（节点上堆叠调度），只支持以FIFO（First In，First Out）策略依次调度应用，无其他控制与调度特性。只适用于及其简单的场景，因此...
MQTT快速入门
如果提前删除 云消息队列 MQTT 版 实例绑定的存储实例，则 云消息队列 MQTT 版 实例会不可用。请按以下步骤创建并绑定存储实例：在左侧导航栏单击 概览，选择您刚创建的 云消息队列 MQTT 版 实例，单击 继续配置。在 消息持久化配置 对话框...
服务器证书管理
服务器证书用于客户端...如果证书错误会导致服务短暂不可用。登录 云消息队列 MQTT 版 控制台，进入 服务器证书 页面。在证书列表中选择指定的服务器证书，并在其 操作 列单击 启动服务。在弹出的提示对话框中仔细阅读提示信息并单击 确认。
直播互动解决方案
同一直播间的客户端发送和订阅消息的Topic需分开创建和使用，以免 云消息队列 RocketMQ 版 形成消费死循环。具体示例如下。场景一：直播互动消息 例如，一个在线教育直播间中有三名成员，一名老师和两名学生。学生A在直播间发文字消息，...
发布者最佳实践
默认情况下，云消息队列 Kafka 版 为了提升可用性，并不保证单个分区内绝对有序，在升级或者宕机时，会发生少量消息乱序（某个分区挂掉后把消息Failover到其它分区）。如果业务要求分区保证严格有序，请在创建Topic时选择使用Local存储。
使用限制
云存储单分区 宕机和升级时可能导致不可用 建议创建的分区数大于1，如果强依赖单分区，可以使用Local存储。说明 仅专业版实例支持在创建Topic时将存储引擎类型选择为Local存储，标准版暂不支持。说明 云消息队列 Kafka 版 不再支持按照...
常见问题
客户端报错 使用云消息队列 Kafka 版时客户端的报错及解决方案 使用云消息队列 Kafka 版时出现“Not authorized to access group”的错误信息 网络问题 无法ping通云消息队列 Kafka 版的接入点 不在同一可用区内的ECS实例如何访问云消息...
功能与特性概述
单个地域内采用多机房部署，可用性极高，即使整个机房都不可用，仍然可以为应用提供消息发布服务。云消息队列 RocketMQ 版 提供TCP和HTTP协议的多语言接入方式，方便不同编程语言开发的应用快速接入 云消息队列 RocketMQ 版 消息云服务。您...
排他队列
如果您想创建一个只有自己可见的队列，不允许其他用户访问，您可以使用 云消息队列 RabbitMQ 版 的排他性队列特性，将指定的队列声明为排他性。什么是排他队列 排他性队列的特点如下：排他队列只对首次声明它的连接（Connection）可见，...
消费者负载均衡
队列分配运维更方便 传统基于绑定队列的负载均衡策略，必须保证队列数量大于等于消费者数量，以免产生部分消费者获取不到队列出现空转的情况，而消息粒度负载均衡策略则无需关注队列数。适用场景 消息粒度消费负载均衡策略下，同一队列内的...
实例管理
已停服 实例不可用。实例的资源和数据保留，可恢复。已释放 实例不可用。实例的资源和数据删除，不可恢复。支持的操作 操作 说明 创建实例 云消息队列 RabbitMQ 版 提供专业版、企业版、铂金版和Serverless版实例。具体规格差异，请参见 ...
迁移自建Kafka集群至新实例
本文介绍如何在 云消息队列 Kafka 版 控制台创建并启动迁移任务。前提条件 下载JDK 8 安装Tsar 为了更准确的获取执行机器的配置，推荐您提前安装Tsar软件。您也可以在运行迁移工具时通过指定-installTsar 参数自动安装Tsar软件，但自动安装...
不在同一可用区内的ECS实例如何访问云消息队列 Kafka ...
概述 不在同一可用区内的ECS实例可通过非公网的方式访问云消息队列 Kafka 版实例，详情请查看以下内容。详细信息 以非公网的方式访问云消息队列 Kafka 版实例时，必须满足以下两个条件：ECS实例与云消息队列 Kafka 版实例在同一VPC网络实例...
按量计费转包年包月
注意事项 按量计费转包年包月的过程中，实例始终处于服务中状态，不会因为实例重启而导致服务短暂不可用。按量计费转包年包月不会改变实例的ID或接入点。操作步骤 登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域，选择...
新增分区时对应的Topic数量额度
可使用的Topic数量与总分区数强相关。例如，您已购买了分区数为50、流量规格为alikafka.hw.2xlarge、规格内赠送分区数为1000的实例，那么该...云消息队列 Kafka 版 Serverless实例不受此项限制。购买分区的操作步骤，请参见 升级实例配置。
实例规格
可用性 99.99%（累计不可用时间最长不超过4.3分钟/月）99.95%（累计不可用时间最长不超过21.5分钟/月）专家尊享通道 产品专家与研发专家在线支持，及时协助处理线上问题。提供保驾护航服务，例如大促保障护航、新业务上线等。云消息队列 ...
产品优势
高可用 提供明确 SLA，保障多可用区高可用，即便整个机房不可用仍可正常提供消息服务。集群分布式部署，服务节点无状态、无单点。即使单节点不可用，请求将Failover至其他节点保障消息服务正常提供。功能增强 延时消息 支持延时消息，实现...
管理资源队列
配置 说明 队列名称 队列名称不可重复，只允许小写字母、数字和中划线（-）且长度不超过32位。说明 资源队列添加成功后，不可修改资源 队列名称。资源量（CU）允许配置的资源量上限由该项目空间剩余的可用资源量决定。如果项目空间可用资源...
升级多可用区
升级影响 该操作服务不会中断，但可能导致短暂不可用。如果客户端无重连机制。可能导致客户端断开连接无法重连。该操作会引发集群部分节点重启。重要 升级多可用区功能当前在灰度状态，如需升级 请 提交工单 申请。操作步骤 登录 云消息...
续费说明
续费规则 续费对象 续费功能仅适用于包年包月的 云消息队列 RocketMQ 版 实例，按量付费实例不需要续费，只要保证您的阿里云账户可用额度充足即可。续费时间 自动续费：实例到期前9天开始触发，持续至到期前1天，每天触发一次，直到续费...
开源MQTT迁移至云消息队列 MQTT 版
具体操作流程如下：使用限制 若迁移前使用的服务端为EMQX开源服务端，则原系统Topic不可用。例如$delayed、$share等以$开头的Topic。迁移前使用过的开源MQTT客户端必须符合MQTT 3.1.1协议。云消息队列 MQTT 版 客户端不支持使用自定义用户...
Token鉴权概述
应用服务器需要做本地容灾，避免因MQTT服务器访问短暂不可用而导致业务阻塞的情况。相关API Token鉴权流程通过相关的API来完成。应用服务器负责Token的申请和吊销管理，和 云消息队列 MQTT 版 服务器之间通过HTTPS的OpenAPI进行交互。每个...
Token鉴权概述
应用服务器需要做本地容灾，避免因MQTT服务器访问短暂不可用而导致业务阻塞的情况。相关API Token鉴权流程通过相关的API来完成。应用服务器负责Token的申请和吊销管理，和 云消息队列 MQTT 版 服务器之间通过HTTPS的OpenAPI进行交互。每个...
一机一密概述
应用服务器需要做本地容灾，避免因MQTT服务器访问短暂不可用而导致业务阻塞的情况。相关API 一机一密鉴权流程通过相关的API来完成。应用服务器负责设备访问凭证的申请和管理，和 云消息队列 MQTT 版 服务器之间通过HTTPS的OpenAPI进行交互...
使用限制
云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时，云消息队列 RocketMQ 版 仅4.0系列实例支持消息流入或流出规则，5.0系列实例不支持。...
队列（MessageQueue）
0：不可读写状态，当前队列不允许任何读写操作。约束：队列的读写权限属于运维侧操作，不建议频繁修改。行为约束 每个主题下会由一到多个队列来存储消息，每个主题对应的队列数与消息类型以及实例所处地域（Region）相关，队列数暂不支持...
产品架构
本文介绍 云消息队列 RocketMQ 版 的系统部署架构，方便您更好地理解 云消息队列 RocketMQ 版 的高可用性。云消息队列 RocketMQ 版 在任何一个环境都是可扩展的，生产者必须是一个集群，消息服务器必须是一个集群，消费者也同样。集群级别...
事务消息
同时，传统的大事务可以被拆分为小事务，不仅能提升效率，还不会因为某一个关联应用的不可用导致整体回滚，从而最大限度保证核心系统的可用性。在极端情况下，如果关联的某一个应用始终无法处理成功，也只需对当前应用进行补偿或数据订正...
应用场景
其高性能的消息处理能力可以承接流量脉冲而不被击垮，在确保系统可用性的同时，通过快速有效的请求响应技术提升用户体验。其海量消息堆积能力确保下游业务在安全水位内平滑稳定地运行，避免流量高峰的冲击。分布式缓存同步 大量并发访问...
作为Output接入
取值：true：如果主分区不可用，输出可能阻塞。false：即使主分区不可用，输出不被阻塞。false ssl.certificate_authorities CA证书所在位置。home/admin/filebeat/filebeat-7.7.0-linux-x86_64/ca-cert ssl.verification_mode 认证模式。...
是否支持优先级队列？
云消息队列 RabbitMQ 版 不支持优先级队列。云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理逻辑，您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。
是否支持优先级队列？
云消息队列 RabbitMQ 版 不支持优先级队列。云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理逻辑，您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。
什么是云消息队列 RocketMQ 版？
当某个可用区不可用时，仍然能够保障服务的正常访问。数据复制：支持跨地域和同地域的数据复制，通过路由规则将消息数据从源实例同步到目标实例中。更多信息，请参见 全球消息路由。稳定性SLA 多可用区部署，提供业内领先的稳定性SLA保障，...
CreateInstance-创建实例
创建云消息队列 RocketMQ 版5.x系列实例。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险...
基本概念
本文说明 云消息队列 Kafka 版 涉及的专有名词和术语，帮助您更好地理解相关概念并使用该产品。Apache Kafka 一款开源的分布式数据流处理平台，可以实时发布、订阅、存储和处理数据流。更多信息，请参见 Apache Kafka。云消息队列 Kafka 版...
从自建MySQL同步至云消息队列 Kafka 版
可能会导致数据库的负载上升，在数据库性能较差、规格较低或业务量较大的情况下（例如源库有大量慢SQL、存在无主键表或目标库存在死锁等），可能会加重数据库压力，甚至导致数据库服务不可用。因此您需要在执行数据同步前评估源库和目标库...
迁移上云操作
和开源Apache RocketMQ相比，阿里云 云消息队列 RocketMQ 版 具有更高的稳定性、安全性及更完善的运维体系。您可以将开源RocketMQ集群迁移到 云消息队列 RocketMQ 版 上以获得更好的业务体验。本文为您介绍如何使用 云消息队列 RocketMQ 版...
开源对比
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品，能够兼容开源RabbitMQ客户端，与开源RabbitMQ相比，能够解决各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等...
- 产品推荐
- 这些文档可能帮助您