Terraform
为用户提供“开箱即用”的使用体验。声明式语言：Terraform使用HCL（HashiCorp Configuration Language）作为配置语言，它是一种声明式的语言，通过描述期望的状态，而不是编写详细的步骤，使得代码更易于理解和维护。可扩展性：Terraform...
什么是云消息队列 Confluent 版？
本文介绍 云消息队列 Confluent 版 的定义。什么是Confluent Platform Confluent Platform是一个全面的数据流企业级平台，使您能够以连续、实时的流形式轻松访问、存储和管理数据。Confluent由Apache Kafka的原始创建者构建，通过企业级...
消费重试
消费者出现异常，云消息队列 RocketMQ 版 会根据消费重试策略重新投递该消息进行故障恢复。本文介绍消费重试的应用场景、原理机制、版本兼容性和使用建议。应用场景 云消息队列 RocketMQ 版 的消费重试主要解决的是业务处理逻辑失败导致的...
新功能发布记录
新增 Serverless后付费 实例规格 弹性策略 2024-04-08 功能名称 功能描述 功能类型 相关文档 升级多可用区 云消息队列 Kafka 版 V2系列 专业版实例支持从单可用区部署升级为多可用区部署架构。新增 升级多可用区 2024-03-30 功能名称 功能...
定时/延时消息
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻...
消息发送重试和流控机制
本文为您介绍 云消息队列 RocketMQ 版 的消息发送重试机制和消息流控机制。背景信息 消息发送重试 云消息队列 RocketMQ 版 的消息发送重试机制主要为您解答如下问题：部分节点异常是否影响消息发送？请求重试是否会阻塞业务调用？请求重试...
云消息队列 RocketMQ 版自定义权限策略
什么是自定义权限策略 在基于RAM的访问控制体系中，自定义权限策略是指在系统权限策略之外，您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您来维护。创建自定义权限策略后，需为RAM用户、用户组或RAM角色绑定权限...
SDK概述
本文介绍 云消息队列 Kafka 版 SDK、支持的多语言SDK。SDK简介 SDK（Software Development Kit）即软件开发工具包，包含示例Demo、库文件、编译工具链以及编译脚本等，不需要开发者进行任何其他的配置，直接可以在SDK对应目录环境下，进行...
队列（MessageQueue）
使用建议 按照实际业务消耗设置队列数 云消息队列 RocketMQ 版 的队列应遵循少用够用原则，避免随意增加队列数量。主题内队列数过多可能导致如下问题：集群元数据膨胀 云消息队列 RocketMQ 版 会以队列粒度采集指标和监控数据，队列过多...
使用ACL功能进行访问控制
当需要对不同的用户或用户组授予不同级别的访问权限时，您可以使用 云消息队列 Kafka 版 专业版 或V3系列Serverless 实例的访问控制列表（ACL）功能，为SASL用户赋予对Topic、Group等资源的操作权限，实现细粒度的权限管理。背景信息 企业A...
接入点对比
云消息队列 Kafka 版 提供默认接入点、SSL接入点和SASL接入点以适用不同的连接及安全需求。默认接入点适用于在保密性较高的VPC环境收发消息；SASL接入点适用于无需对传输链路加密但需对消息收发鉴权；需要链路加密和消息鉴权，建议使用SSL...
消息存储和清理机制
本文为您介绍 云消息队列 RocketMQ 版 中消息的存储机制，包括消息的存储粒度、判断依据及后续处理策略等。背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限...
排他队列
如果您想创建一个只有自己可见的队列，不允许其他用户访问，您可以使用 云消息队列 RabbitMQ 版 的排他性队列特性，将指定的队列声明为排他性。什么是排他队列 排他性队列的特点如下：排他队列只对首次声明它的连接（Connection）可见，...
云消息队列 RabbitMQ 版系统权限策略参考
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）产品提供了两种类型的权限策略：系统策略和自定义策略。系统策略统一由阿里云创建，策略的版本...
消息队列Kafka版系统权限策略参考
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）产品提供了两种类型的权限策略：系统策略和自定义策略。系统策略统一由阿里云创建，策略的版本...
云消息队列 RocketMQ 版4.x系统权限策略参考
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）产品提供了两种类型的权限策略：系统策略和自定义策略。系统策略统一由阿里云创建，策略的版本...
生产者（Producer）
本文介绍 云消息队列 RocketMQ 版 中生产者（Producer）的定义、模型关系、内部属性、版本兼容性及使用建议。定义 生产者是 云消息队列 RocketMQ 版 系统中用来构建并传输消息到服务端的运行实体。生产者通常被集成在业务系统中，将业务...
领域模型概述
消息存储 主题（Topic）：云消息队列 RocketMQ 版 消息传输和存储的分组容器，主题内部由多个队列组成，消息的存储和水平扩展实际是通过主题内的队列实现的。队列（MessageQueue）：云消息队列 RocketMQ 版 消息传输和存储的实际单元容器，...
开源RabbitMQ迁移上云
这里将开源集群中的队列设置为同步任务的源，云消息队列 RabbitMQ 版 实例的队列设置为同步任务的目标。如果在开源集群中，VirtualHost A有来自其它VirtualHost B的Shovel同步任务sync B，则需要将同步任务sync B的目标设置为 云消息队列 ...
消息（Message）
消息队列 定义：实际存储当前消息的队列。更多信息，请参见 队列（MessageQueue）。取值：由服务端指定并填充。消息位点 定义：当前消息存储在队列中的位置。更多信息，请参见 消费进度原理。取值：由服务端指定并填充。取值范围：0~long....
消息队列RabbitMQ版
amq.direct Queue 选择目标 云消息队列 RabbitMQ 版 实例中的队列。仅当 目标类型 参数配置为 Queue 模式 时需要配置该参数。queue Routing Key 路由消息规则。Body 需要投递的事件的消息内容。配置规则，请参见 消息转换。部分事件$.data....
迁移概述
本文介绍将自建Kafka集群迁移到 云消息队列 Kafka 版 实例的优势、原理、方案架构、迁移工具和操作流程。迁移优势 将自建Kafka集群迁移到 云消息队列 Kafka 版 实例的优势，请参见 产品优势。迁移原理 对于消息队列来说，如果要实现集群...
云消息队列 RocketMQ 版5.x系统权限策略参考
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）产品提供了两种类型的权限策略：系统策略和自定义策略。系统策略统一由阿里云创建，策略的版本...
消费进度管理
消费位点（ConsumerOffset）云消息队列 RocketMQ 版 领域模型为发布订阅模式，每个主题的队列都可以被多个消费者分组订阅。若某条消息被某个消费者消费后直接被删除，则其他订阅了该主题的消费者将无法消费该消息。因此，云消息队列 ...
仪表盘
借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 RocketMQ 版 提供仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标，进而快速了解业务的运行状态。本文介绍仪表盘的应用场景、业务背景...
消息过滤
消费者订阅了某个主题后，云消息队列 RocketMQ 版 会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息，可通过设置过滤条件在 云消息队列 RocketMQ 版 服务端进行过滤，只获取到需要关注的消息子集，避免接收到大量无效的...
产品优势
开箱即用 云消息队列 Kafka 版 100%兼容开源，使您无缝迁移上云。兼容开源：云消息队列 Kafka 版 100%兼容开源Apache Kafka，您可以直接使用开源Apache Kafka客户端与 云消息队列 Kafka 版 通讯。云消息队列 Kafka 版 目前支持0.10.x~2.6.x...
消息轨迹
在分布式应用中，云消息队列 RocketMQ 版 作为全链路中异步解耦的关键服务，提供的消息轨迹数据可有效将业务上下游信息串联起来，帮助您更好地排查异常信息，定位问题。本文介绍消息轨迹的使用场景、云消息队列 RocketMQ 版 定义的轨迹参数...
权限策略
云消息队列 MQTT 版 权限管理是通过阿里云的访问控制RAM（Resource Access Management）实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKey ID和AccessKey Secret），按需为用户分配最小权限。本文介绍 云...
创建RabbitMQ Sink Connector
exchange Queue 当 目标类型 为 Queue 时，选择 云消息队列 RabbitMQ 版 中的选择接收消息的队列。queue 消息路由规则（Routing Key）事件总线EventBridge 通过JSONPath提取事件中的数据，将指定的事件内容路由到事件目标。当 目标类型 为 ...
删除队列消息
本文介绍如何删除某个队列的所有消息。您可以使用Java客户端库中 queuePurge 方法删除某个队列的所有消息。示例代码如下：channel.queuePurge("queue-name");
云消息队列 RabbitMQ 版
vhost Queue 选择源实例中的队列。queue 表 2.目标端云消息队列 RocketMQ 版参数配置 参数 说明 示例 地域 接收 云消息队列 RocketMQ 版 消息的目标实例所在的地域。华东1（杭州）版本 选择目标端 云消息队列 RocketMQ 版 实例的版本。...
创建RabbitMQ Source Connector
test Queue 选择存储消息的队列。test 批量推送 批量推送可帮您批量聚合多个事件，当 批量推送条数 和 批量推送间隔（单位：秒）两者条件达到其一时即会触发批量推送。例如：您设置的推送条数为100 条，间隔时间为15 s，在10 s内消息条数已...
消息队列RabbitMQ版
vhost Queue 选择源实例中的队列。queue 表 2.目标端消息队列RocketMQ版参数配置 参数 说明 示例 地域 接收 云消息队列 RocketMQ 版 消息的目标实例所在的地域。华东1（杭州）版本 选择目标端 云消息队列 RocketMQ 版 实例的版本。RocketMQ...
消费者负载均衡
因此，在消费者数量、队列数量发生变化时，可能会出现短暂的队列分配结果不一致，从而导致少量消息被重复处理。策略特点 相对于消息粒度负载均衡策略，队列粒度负载均衡策略分配粒度较大，不够灵活。但该策略在流式处理场景下有天然优势，...
计费常见问题
本文汇总了 云消息队列 RocketMQ 版 计费的常见问题。每天扣除2元，这是什么费用？我昨天删除了Topic，为什么今天会收到账单并被扣费？我没有使用 云消息队列 RocketMQ 版 服务，为什么会扣费？我在控制台上看到没有开通 云消息队列 ...
消息服务MNS
华东1（杭州）队列名称 选择源端 消息服务MNS 的队列。test 开启 Base64 编码 默认勾选此项。开启Base64编码，会帮助您将 消息服务MNS 的数据编码后投递至目标端。无 表 2.目标端云消息队列 RocketMQ 版参数配置 参数 说明 示例 地域 接收 ...
消息服务MNS
华东1（杭州）队列名称 选择源端 消息服务MNS 的队列。test 开启 Base64 编码 默认勾选此项。开启Base64编码，会帮助您将 消息服务MNS 的数据编码后投递至目标端。无 表 2.目标端云消息队列 RocketMQ 版参数配置 参数 说明 示例 地域 接收 ...
消息服务MNS
test 开启 Base64编码 是：开启Base64编码，会帮助您将数据编码后投递至 消息服务MNS 中的队列。否：不开启Base64编码。是 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用...
消息服务MNS
华东1（杭州）队列名称 选择源端 消息服务MNS 的队列。test 开启 Base64 编码 默认勾选此项。开启Base64编码，会帮助您将 消息服务MNS 的数据编码后投递至目标端。无 表 2.目标端消息队列RabbitMQ版参数配置 参数 说明 示例 地域 选择接收...
- 产品推荐
- 这些文档可能帮助您