在左侧导航栏，单击 队列管理。单击 添加队列。填写 队列名称 和 资源量。配置 说明 队列名称 队列名称不可重复，只允许小写字母、数字和中划线（-）且长度不超过32位。说明 资源队列添加成功后，不可修改资源 队列名称。资源量（CU）允许...
主要特性 CapacityScheduler具备如下的特性：多级队列（树形结构）：支持多级租户管理，父队列资源配额能够限制其下所有子队列的资源使用，单个子队列的资源配额也不能超过父队列的资源配额，因此对于多租户管理具备较高的可控性，能够满足...
云消息队列 MQTT 版 支持使用设备证书进行客户端的接入认证，CA证书可用于签发设备证书、服务器证书和验证证书，客户端使用设备证书进行认证时，服务端将使用设备证书关联的CA证书来验证设备证书是否正确，CA证书必须在 云消息队列 MQTT 版...
新增 弹性TPS计费 实例管理 2022-12-22 功能名称 功能描述 功能类型 相关文档 Exchange管理 云消息队列 RabbitMQ 版 兼容开源RabbitMQ支持的x-consistent-hash类型Exchange，无需安装插件，您只需声明该类型Exchange即可使用。新增 ...
云消息队列 Kafka 版 可以作为Input接入Filebeat。本文说明如何在VPC环境下通过Filebeat从 云消息队列 Kafka 版 消费消息。背景信息 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 VPC...
云消息队列 Kafka 版 可以作为Output接入Filebeat。本文说明如何在VPC环境下通过Filebeat向 云消息队列 Kafka 版 发送消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。更多信息，请参见 VPC...
云消息队列 Kafka 版 可以作为Input接入Filebeat。本文说明如何在公网环境下通过Filebeat从 云消息队列 Kafka 版 消费消息。背景信息 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
云消息队列 Kafka 版 可以作为Input接入Logstash。本文说明如何在VPC环境下通过Logstash从 云消息队列 Kafka 版 消费消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 VPC...
云消息队列 Kafka 版 可以作为Output接入Logstash。本文说明如何在VPC环境下通过Logstash向 云消息队列 Kafka 版 发送消息。前提条件 购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 VPC接入。下载并安装Logstash。具体操作，请...
云消息队列 Kafka 版 可以作为Output接入Filebeat。本文说明如何在公网环境下通过Filebeat向 云消息队列 Kafka 版 发送消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
云消息队列 Kafka 版 可以作为Output接入Logstash。本文说明如何在公网环境下通过Logstash向 云消息队列 Kafka 版 发送消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
云消息队列 Kafka 版 可以作为Input接入Logstash。本文说明如何在公网环境下通过Logstash从 云消息队列 Kafka 版 消费消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
服务器证书用于客户端认证服务端，服务器证书需要由您自行购买或自行签发并托管至阿里云数字证书管理服务。本文为您介绍如何生成并使用服务器证书。服务器证书使用流程 使用限制 仅铂金版实例和专业版实例支持服务器证书管理功能。前提条件...
您可以在 云消息队列 Kafka 版 控制台 的 Topic 管理 页面创建。具体操作，请参见 步骤三：创建资源。canal.mq.dynamicTopic 否 动态Topic规则表达式。设置Topic匹配规则表达式，可以将不同的数据表数据同步至不同的Topic。具体设置方法，...
安装IDEA 安装1.8或以上版本JDK 安装2.5或以上版本Maven Demo工程示例 amqp-springboot-demo amqp-spring-demo 步骤一：引入Java依赖 创建Java工程，在 pom.xml 文件中添加如下依赖：<dependency><groupId>org.springframework.boot...
消息在队列中的存储情况如下：消息存储管理粒度说明 云消息队列 RocketMQ 版 按照服务端节点粒度管理存储时长而非队列或主题，原因如下：消息存储优势权衡：云消息队列 RocketMQ 版 基于统一的物理日志队列和轻量化逻辑队列的二级组织方式...
本文介绍如何使用队列分组管理计算节点，包括创建和删除队列，以及在队列之间移动节点。背景信息 创建集群时会自动创建一个默认队列，计算节点默认会加入到该队列中。操作步骤 打开 节点与队列 页面。登录 弹性高性能计算控制台。在顶部...
智能设备管理：例如，通过安装在手机上的App向接入到 云消息队列 MQTT 版 服务端的共享充电宝下发指令，充电宝收到指令消息后自动弹出。终端和云端消息收发 该场景下消息的发送端和消费端分别为移动终端设备和部署在阿里云上的业务应用。...
云消息队列 RabbitMQ 版 存储加密默认采用行业标准的AES-256加密算法，利用密钥管理服务KMS（Key Management Service）加密您的数据信息，该项能力完全免费。传输加密 使用限制 传输加密仅Serverless版、企业版、铂金版实例支持，专业版...
本文描述云消息队列 RocketMQ 版4.x支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问...
本文描述云消息队列 RabbitMQ 版支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制...
本文描述消息队列Kafka版支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）...
消费时间过慢，超过一定时间（max.poll.interval.ms 设置的值，默认5分钟）未进行Pull拉取消息，则会导致客户端主动离开队列，触发Rebalance。消费者数量过多，为避免当前Topic-Partition的任务浪费，需要关闭一定数量的消费者，触发...
本文介绍 云消息队列 Kafka 版 的产品功能动态及对应的文档。2024-04-15 功能名称 功能描述 功能类型 相关文档 V3.0 Serverless系列实例在华东2（上海）地域开服 云消息队列 Kafka 版 V3.0 Serverless系列实例支持在华东2（上海）地域选购...
消费流量 Group与Topic的订阅关系 服务端小版本升级 消费位点提交频率 存在Rebalance的Group 消费客户端主动离开队列 使用Sarama Go客户端 操作步骤 登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。...
OpenAPI是阿里云产品提供的开放应用程序接口，是除控制台之外，云消息队列 RocketMQ 版 管理资源的主要方式之一。API参考汇总了 云消息队列 RocketMQ 版 所有对外公开的API接口。云消息队列 RocketMQ 版5.x系列 5.x系列SDK参考 5.x系列API...
虽然删除了Vhost、Exchange、Queue，但Producer和Consumer依然与 云消息队列 RabbitMQ 版 保持连接，即代码逻辑层面还在主动发起连接到 云消息队列 RabbitMQ 版 的请求。连接的参数指向之前被删除的资源，根据AMQP 0-9-1协议这些资源将被...
本文介绍使用C++ SDK v2.x.x版本接入 云消息队列 RocketMQ 版 所需完成的准备工作、使用说明以及注意事项，以便后续使用C++ SDK收发消息。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ ...
本文介绍使用C++ SDK v2.x.x及以上版本接入 云消息队列 RocketMQ 版 所需完成的准备工作、使用说明以及注意事项，以便后续使用C++ SDK收发消息。使用前，请注意以下几点：本文仅针对C++ SDK v2.x.x及以上版本进行说明，若您需从当前使用的v...
虽然删除了Vhost、Exchange、Queue，但Producer和Consumer依然与 云消息队列 RabbitMQ 版 保持连接，即代码逻辑层面还在主动发起连接到 云消息队列 RabbitMQ 版 的请求。连接的参数指向之前被删除的资源，根据AMQP 0-9-1协议这些资源将被...
本文介绍如何使用CA证书签发设备证书，并在 云消息队列 MQTT 版 控制台管理设备证书，包括查询证书、下载证书、激活或注销证书以及删除证书。背景信息 设备证书是由CA根证书签发给客户端设备使用的数字证书，用于客户端和服务端连接时，...
若您在停服后72小时内未补足欠款，阿里云将主动为您释放 云消息队列 RocketMQ 版 实例，并且删除您实例下创建的Topic与Group ID，被释放的实例以及资源均不可恢复。企业铂金版实例（包年包月）的欠费说明 云消息队列 RocketMQ 版 的企业...
通过 云消息队列 MQTT 版 所提供的服务，可采用统一的框架，即云控制台，来管理不同部署模式的云存储网关CSG（Cloud Storage Gateway），并实现安全合规的公网和私网穿透，以此提供一致的用户体验。名词解释 MQTT 一种物联网和移动互联网...
本文说明 云消息队列 Kafka 版 涉及的专有名词和术语，帮助您更好地理解相关概念并使用该产品。Apache Kafka 一款开源的分布式数据流处理平台，可以实时发布、订阅、存储和处理数据流。更多信息，请参见 Apache Kafka。云消息队列 Kafka 版...
本文介绍如何使用Ruby SDK通过接入点接入 云消息队列 Kafka 版 并收发消息。环境准备 您已安装Ruby。更多信息，请参见 安装Ruby。安装Ruby依赖库 执行以下命令安装Ruby依赖库。gem install ruby-kafka-v 0.6.8 准备配置 可选：下载SSL根...
队列粒度的负载均衡，基于队列数量、消费者数量等运行数据进行统一的算法分配，将每个队列绑定到特定的消费者，然后每个消费者按照取消息>提交消费位点>持久化消费位点的消费语义处理消息，取消息过程不提交消费状态，因此，为了避免消息被...
您可在 云消息队列 Kafka 版 控制台 的 Topic 管理 页面获取。consumer_id Group 名称。您可在 云消息队列 Kafka 版 控制台 的 Group 管理 页面获取。配置完成后，将配置文件所在文件夹下的全部文件（如果是SSL接入点实例，包含证书SSL根...
云消息队列 RocketMQ 版 支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息 云消息队列 RocketMQ 版 面向不同的业务场景提供了不同...
Spring Cloud是用于构建消息驱动的微服务应用程序的框架，提供服务发现、配置管理、消息传递、负载均衡等微服务相关的解决方案，可以更容易地构建分布式系统和进行服务间通信。本文介绍如何使用Spring Cloud框架接入 云消息队列 Kafka 版 ...
SDK列表 云消息队列 Kafka 版 提供了以下编程语言的SDK，您可以在获取地址中查看更新历史、获取安装包以及查看指导文档。SDK Demo地址 适用的协议 参考文档 说明文件 Java SDK Java SDK Demo PLAINTEXT SASL_SSL/PLAIN SASL_PLAINTEXT/...