新功能发布记录
新增 Serverless后付费 实例规格 弹性策略 2024-04-08 功能名称 功能描述 功能类型 相关文档 升级多可用区 云消息队列 Kafka 版 V2系列 专业版实例支持从单可用区部署升级为多可用区部署架构。新增 升级多可用区 2024-03-12 功能名称 功能...
Terraform
常用命令 Terraform对资源的管理主要是对资源生命周期的管理，即通过命令实现对Terraform模板中所定义资源的创建，修改，查看和删除。常用命令，请参见 Terraform常用命令。使用优势 从宏观角度而言，Terraform优势如下：基础设施即代码：...
计费FAQ
虽然删除了Vhost、Exchange、Queue，但Producer和Consumer依然与 云消息队列 RabbitMQ 版 保持连接，即代码逻辑层面还在主动发起连接到 云消息队列 RabbitMQ 版 的请求。连接的参数指向之前被删除的资源，根据AMQP 0-9-1协议这些资源将被...
计费FAQ
虽然删除了Vhost、Exchange、Queue，但Producer和Consumer依然与 云消息队列 RabbitMQ 版 保持连接，即代码逻辑层面还在主动发起连接到 云消息队列 RabbitMQ 版 的请求。连接的参数指向之前被删除的资源，根据AMQP 0-9-1协议这些资源将被...
云消息队列 RocketMQ 版4.x系统权限策略参考
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）产品提供了两种类型的权限策略：系统策略和自定义策略。系统策略统一由阿里云创建，策略的版本...
权限策略
云消息队列 MQTT 版 权限管理是通过阿里云的访问控制RAM（Resource Access Management）实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKey ID和AccessKey Secret），按需为用户分配最小权限。本文介绍 云...
云消息队列 RabbitMQ 版系统权限策略参考
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）产品提供了两种类型的权限策略：系统策略和自定义策略。系统策略统一由阿里云创建，策略的版本...
基本概念
本文说明 云消息队列 Kafka 版 涉及的专有名词和术语，帮助您更好地理解相关概念并使用该产品。Apache Kafka 一款开源的分布式数据流处理平台，可以实时发布、订阅、存储和处理数据流。更多信息，请参见 Apache Kafka。云消息队列 Kafka 版...
什么是云消息队列 Confluent 版？
什么是Confluent Platform Confluent Platform是一个全面的数据流企业级平台，使您能够以连续、实时的流形式轻松访问、存储和管理数据。Confluent由Apache Kafka的原始创建者构建，通过企业级功能扩展了Kafka的优势，同时消除了Kafka管理或...
消费者负载均衡
消费者从 云消息队列 RocketMQ 版 获取消息消费时，通过消费者负载均衡策略，可将主题内的消息分配给指定消费者分组中的多个消费者共同分担，提高消费并发能力和消费者的水平扩展能力。本文介绍 云消息队列 RocketMQ 版 消费者的负载均衡...
消息队列Kafka版系统权限策略参考
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）产品提供了两种类型的权限策略：系统策略和自定义策略。系统策略统一由阿里云创建，策略的版本...
云消息队列 RocketMQ 版5.x系统权限策略参考
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）产品提供了两种类型的权限策略：系统策略和自定义策略。系统策略统一由阿里云创建，策略的版本...
云存储网关利用MQTT服务实现统一管控
注意事项 上述流程简要描述了如何使用 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 实现统一的跨网络的管理架构，具体的SDK说明，请参见 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 文档。其中使用 云消息队列 MQTT 版 构建跨网络的...
权限策略
云消息队列 MQTT 版 权限管理是通过阿里云的访问控制RAM（Resource Access Management）实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKey ID和AccessKey Secret），按需为用户分配最小权限。本文介绍 云...
消息发送重试和流控机制
本文为您介绍 云消息队列 RocketMQ 版 的消息发送重试机制和消息流控机制。背景信息 消息发送重试 云消息队列 RocketMQ 版 的消息发送重试机制主要为您解答如下问题：部分节点异常是否影响消息发送？请求重试是否会阻塞业务调用？请求重试...
订阅者最佳实践
本文主要介绍 云消息队列 Kafka 版 订阅者的最佳实践，帮助您减少消费消息出错的可能性。消费消息基本流程 云消息队列 Kafka 版 订阅者在订阅消息时的基本流程为：Poll数据→执行消费逻辑→再次Poll数据，详情参见下图。负载均衡 每个 ...
MNS回调事件通知
MNS提供了队列模型，支持多个生产者和消费者并发访问同一个队列，并能确保某条消息在取出之后的特定时间段内，无法被其他消费者获得。消息被消费后一段时间内不可见，需要用户主动删除，否则该消息会被再次消费。视频点播服务VOD支持通过...
定时/延时消息
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻...
使用Canal将MySQL的数据同步至云消息队列 Kafka 版
本教程介绍如何使用Canal将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Canal的主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。Canal伪装自己为MySQL Slave，向MySQL Master发送dump请求。MySQL Master收到dump...
一机一密概述
当设备与 云消息队列 MQTT 版 建立连接时，需要将设备访问凭证中的信息按照约定的形式设置到Username和Password中，向 云消息队列 MQTT 版 发起认证请求，云消息队列 MQTT 版 认证通过后激活设备，设备与 云消息队列 MQTT 版 间才可传输...
将云消息队列 Kafka 版接入阿里云Elasticsearch
随着时间的积累，云消息队列 Kafka 版 中的日志数据会越来越多。当您需要查看并分析庞杂的日志数据时，可通过阿里云Logstash将 云消息队列 Kafka 版 中的日志数据导入阿里云Elasticsearch，然后通过Kibana进行可视化展示与分析。本文介绍将...
使用云消息队列 Kafka 版时出现消息堆积
使用 云消息队列 Kafka 版 时，可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况，以及处理方法。客户端消费流程 了解客户端消费流程，有助于理解消息是否堆积。一般情况下，客户端消费流程大致如下：判断消息...
自定义鉴权模式
过期设置：云消息队列 MQTT 版 对于身份认证、资源授权以及连接黑名单等数据暂不提供过期设置功能，您可以及时删除相关接口进行管理。容量限制：无论是身份认证，还是资源权限都占用了实例的元数据存储，所以您需要自行管理鉴权数据，及时...
云消息队列 RocketMQ 版自定义权限策略
什么是自定义权限策略 在基于RAM的访问控制体系中，自定义权限策略是指在系统权限策略之外，您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您来维护。创建自定义权限策略后，需为RAM用户、用户组或RAM角色绑定权限...
资源包说明
云消息队列 RocketMQ 版 的标准版实例按照按量付费方式对API请求资源和Topic资源进行计费，针对这两个计费项，云消息队列 RocketMQ 版 分别推出API请求次数和Topic次数资源包，帮助您以更优惠的价格享受等量资源。使用的资源在资源包规格内...
开通消息队列服务并授权
权限策略名称 说明 AliyunMQFullAccess 云消息队列 RocketMQ 版 的管理权限，等同于阿里云账号的权限，被授予该权限的RAM用户具有所有消息收发权限且有控制台所有功能操作权限。AliyunMQPubOnlyAccess 云消息队列 RocketMQ 版 的发布权限，...
开通消息队列服务并授权
权限策略名称 说明 AliyunMQFullAccess 云消息队列 RocketMQ 版 的管理权限，等同于阿里云账号的权限，被授予该权限的RAM用户具有所有消息收发权限且有控制台所有功能操作权限。AliyunMQPubOnlyAccess 云消息队列 RocketMQ 版 的发布权限，...
步骤一：（可选）RAM用户授权
授权策略名称 说明 AliyunAMQPFullAccess 云消息队列 RabbitMQ 版 的管理权限，被授予该权限的RAM用户具有等同于阿里云账号的权限，即资源以及SDK收发消息的所有权限。AliyunAMQPReadOnlyAccess 云消息队列 RabbitMQ 版 的只读权限，被授予...
步骤一：（可选）RAM用户授权
权限策略名称 说明 AliyunMQFullAccess 云消息队列 RocketMQ 版 的管理权限，等同于阿里云账号的权限，被授予该权限的RAM用户具有所有消息收发权限及控制台和API的所有操作权限。AliyunMQReadOnlyAccess 云消息队列 RocketMQ 版 的只读权限...
数据加密
云消息队列 RabbitMQ 版 存储加密默认采用行业标准的AES-256加密算法，利用密钥管理服务KMS（Key Management Service）加密您的数据信息，该项能力完全免费。传输加密 使用限制 传输加密仅Serverless版、企业版、铂金版实例支持，专业版...
开发参考
本文介绍 云消息队列 RocketMQ 版 的SDK和API的支持情况，供您进行对应的开发操作。云消息队列 RocketMQ 版 消息收发需要通过调用SDK完成，云消息队列 RocketMQ 版 的SDK支持Java、C++、.NET、Go等多语言开发。SDK参考提供了各语言的SDK的...
管理资源队列
在左侧导航栏，单击 队列管理。单击 添加队列。填写 队列名称 和 资源量。配置 说明 队列名称 队列名称不可重复，只允许小写字母、数字和中划线（-）且长度不超过32位。说明 资源队列添加成功后，不可修改资源 队列名称。资源量（CU）允许...
配置消息日志
您可以使用 云消息队列 RabbitMQ 版 的日志管理功能将 云消息队列 RabbitMQ 版 实例的消息操作日志推送到日志服务。当消息的发送、消费、确认出现异常时，您可在日志服务查询并分析消息的操作日志，进行异常诊断。前提条件 创建 云消息队列...
MQTT与RocketMQ的消息结构映射
本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景，提供交互中所涉及的消息结构和属性字段的映射关系，方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品，可通过数据互通...
消息存储和清理机制
消息在队列中的存储情况如下：消息存储管理粒度说明 云消息队列 RocketMQ 版 按照服务端节点粒度管理存储时长而非队列或主题，原因如下：消息存储优势权衡：云消息队列 RocketMQ 版 基于统一的物理日志队列和轻量化逻辑队列的二级组织方式...
队列（MessageQueue）
队列的主要作用如下：存储顺序性 队列天然具备顺序性，即消息按照进入队列的顺序写入存储，同一队列间的消息天然存在顺序关系，队列头部为最早写入的消息，队列尾部为最新写入的消息。消息在队列中的位置和消息之间的顺序通过位点（Offset...
Control Center基本使用
Control Center是 云消息队列 Confluent 版 的核心管理服务，提供了一个可视化的监控平台。本文介绍Control Center平台上的基本操作。登录Control Center 创建 云消息队列 Confluent 版 集群，详情请参见 购买和部署实例。在 云消息队列 ...
收发事务消息
云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求，因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...
查看Rebalance详情
消费时间过慢，超过一定时间（max.poll.interval.ms 设置的值，默认5分钟）未进行Pull拉取消息，则会导致客户端主动离开队列，触发Rebalance。消费者数量过多，为避免当前Topic-Partition的任务浪费，需要关闭一定数量的消费者，触发...
基于日志服务的日志说明
云消息队列 RabbitMQ 版 的日志管理功能将 云消息队列 RabbitMQ 版 实例的消息操作日志推送到日志服务，通过SLS分析语句快速查询并统计TPS流量图表。本文介绍SLS中日志字段和请求方法。字段说明 查询的日志字段说明如下表所示。表 1.日志...
- 产品推荐
- 这些文档可能帮助您