设置基线优先级与YARN队列优先级的映射关系
在DataWorks中，可通过节点所在基线的优先级与YARN队列优先级的映射关系，来调整该节点最终的YARN队列优先级。本文为您介绍如何设置基线优先级与YARN队列的映射关系。背景信息 YARN是一个分布式的资源管理系统，用于管理及调度E-MapReduce...
设置全局YARN资源队列
同时，可定义全局YARN资源队列优先级是否高于指定模块内配置的YARN资源队列优先级。本文为您介绍如何设置全局YARN资源队列。背景信息 YARN是一个分布式的资源管理系统，是Hadoop的核心组件，在Hadoop集群中主要负责资源管理、调度运行及...
是否支持优先级队列？
云消息队列 RabbitMQ 版 不支持优先级队列。云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理逻辑，您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。
是否支持优先级队列？
云消息队列 RabbitMQ 版 不支持优先级队列。云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理逻辑，您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。
Filebeat发送失败问题
问题现象 在 云消息队列 Kafka 版 控制台 的 Topic 管理 页面，您已成功创建Topic，但使用Filebeat向该Topic发送消息却出现 Request ...解决方案 在 云消息队列 Kafka 版 控制台 的 Topic 管理 页面创建Topic，请使用全小写字母给Topic命名。
Interactive型资源组的优先级队列与并发控制
每个资源组都有自己的一组优先级队列，包括LOWEST队列、LOW队列、NORMAL队列和HIGH队列。您可以设置查询的优先级，使不同查询进入不同的优先级队列，并通过修改队列并发数来对查询进行限流或放大并发。本文介绍如何设置查询的优先级，以及...
YARN调度器
还要能协调好大量应用在集群的运行，基于多租户（队列）公平性、应用优先级等策略解决好资源竞争等问题；也要能满足个别应用在节点依赖、放置策略等方面的特殊需求。YARN调度器是可拔插的插件，主要有FIFOScheduler、FairScheduler和...
创建高速通道QoS队列
高优先级队列数量有上限，如果需要提升配额，请联系商务经理。普通优先级队列数量有上限，如果需要提升配额，请联系商务经理。所有普通优先级队列的带宽百分比之和有上限。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名...
创建高速通道QoS队列
高优先级队列数量有上限，如果需要提升配额，请联系商务经理。普通优先级队列数量有上限，如果需要提升配额，请联系商务经理。所有普通优先级队列的带宽百分比之和有上限。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名...
Job型资源组的优先级队列
AnalyticDB MySQL版 湖仓版（3.0）Job型资源组内提供了作业优先级队列的能力，您可以设置作业的优先级，使不同作业进入不同的优先级队列（包括LOWEST队列、LOW队列、NORMAL队列和HIGH队列）。优先级高的作业会先运行。设置作业优先级 作业...
产品功能
说明 云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理逻辑，您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。Exchange：支持将消息按照规则路由到一个或多个Queue，同时对不符合路由规则的消息进行丢弃。...
常见问题
客户端报错 使用云消息队列 Kafka 版时客户端的报错及解决方案 使用云消息队列 Kafka 版时出现“Not authorized to access group”的错误信息 网络问题 无法ping通云消息队列 Kafka 版的接入点 不在同一可用区内的ECS实例如何访问云消息...
QoS策略
以下为您列举QoS策略涉及的关键名词：名词 说明 高级队列 高优先级的队列，会对高优先级业务流量优先进行带宽分配，保障高优先级业务的流量转发。普通队列 普通优先级的队列，会对剩余高级队列未使用的带宽根据带宽比例进行带宽分配，普通...
No route info of this topic”错误
解决方案 登录 云消息队列 RocketMQ 版 控制台。在 实例详情 页面查看实例的接入点，检查代码中设置的接入点是否和控制台提供的一致。在 Topic 管理 页面查看代码中设置的Topic是否已创建且拼写正确。在 实例详情 页面的 基础信息 区域查看...
产品优势
本文主要介绍 云消息队列 RabbitMQ 版 相比于自建开源RabbitMQ所具备的优势，以便您更进一步了解 云消息队列 RabbitMQ 版。灵活易用 开箱即用 完全兼容 AMQP 0-9-1 标准协议，完全兼容RabbitMQ开源社区，快速迁移上云。全托管服务 一键开通...
AMQP协议返回码
本文说明 云消息队列 RabbitMQ 版 客户端调用AMQP 0-9-1协议时的返回码，您可以根据返回信息与解决方案自助排查错误。返回码列表 返回码（reply-code）返回信息（reply-text）描述 解决方案 200 no route has mandatory 调用 basicPublish ...
使用云消息队列 Kafka 版时出现“Not authorized to ...
问题描述 使用云消息队列 Kafka 版时出现“Not authorized to access group”的错误信息。问题原因 没有创建Consumer Group时会遇到此报错信息。解决方案 您可以选择如下任意一种方式创建Consumer Group。在云消息队列 Kafka 版的控制台...
错误码列表
如果成功调用 云消息队列 MQTT 版 的OpenAPI，则会返回给客户端ResponseCode=200；如果调用失败，会返回对应的异常错误码以及描述信息。您可以根据以下异常信息对照表查找对应的解决方法。Token相关错误码 HttpCode 错误码 错误信息 描述 ...
错误码列表
如果成功调用 云消息队列 MQTT 版 的OpenAPI，则会返回给客户端ResponseCode=200；如果调用失败，会返回对应的异常错误码以及描述信息。您可以根据以下异常信息对照表查找对应的解决方法。Token相关错误码 HttpCode 错误码 错误信息 描述 ...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 联合 阿里云云监控 提供了开箱即用且免费的监控报警服务，可帮助您解决如下问题：实例规格水位监控预警 若您实际使用的指标值超过实例的规格限制，云消息队列 RocketMQ 版 会进行强制限流。提前配置实例规格水位告...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 联合 阿里云云监控 提供了开箱即用且免费的监控报警服务，可帮助您解决如下问题：实例规格水位监控预警 若您实际使用的指标值超过实例的规格限制，云消息队列 RocketMQ 版 会进行强制限流。提前配置实例规格水位告...
可观测性体系概述
作为一款典型的分布式中间件产品，云消息队列 RocketMQ 版 被广泛应用于业务核心链路中，每条消息都关联着核心业务数据的变化，通过可观测能力及时发现问题、定位问题、解决问题对于业务运行是一项重要的保障能力。本文介绍 云消息队列 ...
消息堆积和延迟问题
本文主要介绍 云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中，经常会出现的消息堆积和消息延迟的问题。通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或...
使用云消息队列 Kafka 版时客户端的报错及解决方案
在使用云消息队列 Kafka 版时，客户端可能报错，您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权（sasl.mechanisms）...
使用RabbitMQ Connector同步RabbitMQ数据
本文介绍如何创建RabbitMQ Connector，将 云消息队列 RabbitMQ 版 的数据同步至 云消息队列 Kafka 版。前提条件 开通事件总线EventBridge并授权。创建RabbitMQ资源。开通对象存储OSS服务并创建存储空间（Bucket）。更多信息，请参见 控制台...
云存储网关利用MQTT服务实现统一管控
通过 云消息队列 MQTT 版 所提供的服务，可采用统一的框架，即云控制台，来管理不同部署模式的云存储网关CSG（Cloud Storage Gateway），并实现安全合规的公网和私网穿透，以此提供一致的用户体验。名词解释 MQTT 一种物联网和移动互联网...
开源对比
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品，能够兼容开源RabbitMQ客户端，与开源RabbitMQ相比，能够解决各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等...
为什么在控制台看不到Group的订阅关系？
问题现象 您已启动某个Group的消费线程，但在 云消息队列 Kafka 版 控制台 的 Topic 详情 页面的 订阅关系 页签，查不到Topic被Group订阅的信息，或者在 Group 详情 页面的 消费状态 页签，查不到该Group订阅的Topic信息。可能原因 客户端...
QueueHasDiffField
本文为您介绍 云消息队列 RabbitMQ 版 客户端报QueueHasDiffField类型错误的原因和处理方法。问题现象 使用 云消息队列 RabbitMQ 版 客户端连接 云消息队列 RabbitMQ 版 服务端时，报QueueHasDiffField类型错误。例如QueueHasDiffField...
ExchangeHasDiffFields
介绍 云消息队列 RabbitMQ 版 客户端报ExchangeHasDiffFields类型错误的原因和处理方法。问题现象 使用 云消息队列 RabbitMQ 版 客户端连接 云消息队列 RabbitMQ 版 服务端时，报ExchangeHasDiffFields类型错误。例如ExchangeHasDiffFields...
音视频通信解决方案（MQTT）
音视频通信解决方案是由阿里云 云消息队列 MQTT 版 和音视频通信RTC联合推出的有助于快速搭建各种实时通信场景产品，譬如在线音视频会议、1对1语音通话应用的解决方案。本文将详细描述该解决方案的系统架构、数据流设计以及相关注意事项。...
迁移上云操作
和开源Apache RocketMQ相比，阿里云 云消息队列 RocketMQ 版 具有更高的稳定性、安全性及更完善的运维体系。您可以将开源RocketMQ集群迁移到 云消息队列 RocketMQ 版 上以获得更好的业务体验。本文为您介绍如何使用 云消息队列 RocketMQ 版...
消息过滤
云消息队列 RocketMQ 版 主要解决的单个业务域即同一个主题内不同消息子集的过滤问题，一般是基于同一业务下更具体的分类进行过滤匹配。如果是需要对不同业务域的消息进行拆分，建议使用不同主题处理不同业务域的消息。功能概述 消息过滤...
发送消息报“Cluster authorization failed”错误
问题描述 开启幂等功能后，发送消息时客户端报 Cluster authorization failed 错误。问题原因 您使用了云存储Topic，云存储Topic不支持幂等功能。如果使用Local Topic，并开启了ACL功能，默认情况下，根据Kafka开源协议，Broker会判断发送...
发布者最佳实践
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future...
消费者分类
云消息队列 RocketMQ 版 支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息 云消息队列 RocketMQ 版 面向不同的业务场景提供了不同...
版本说明
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
事务消息
事务消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...
鉴权常见问题
本文介绍 云消息队列 MQTT 版 终端和云端鉴权的常见问题。终端鉴权 Token鉴权和一机一密鉴权如何选择？使用Token鉴权模式，客户端连接断开并返回“resource auth failed”错误。申请Token权限能同时赋予多种权限吗？为什么已经调用Token...
CreateQueue
MaximumPriority Integer 否 10 不支持优先级功能。取值不影响调用和返回结果。返回数据 名称 类型 示例值 描述 RequestId String 59B52E2C-0B8E-44EC-A314-D0314A50*请求ID。示例 请求示例 http(s):/amqp-open....
- 产品推荐
- 这些文档可能帮助您