本文说明如何为 云消息队列 Kafka 版 实例开启Connector。前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且该实例必须满足以下条件：项目 说明 状态 服务中 版本 云消息队列 Kafka 版 实例的版本必须满足以下任意一种要求：大版本为0...
本文介绍 轻量消息队列（原 MNS）作为事件总线、事件流的源（Source）和目标（Sink）的功能说明和操作指南。作为事件总线的源（Source）和目标（Sink）功能描述 支持将 轻量消息队列（原 MNS）的队列作为 事件总线 的事件源（Source）或者...
本文介绍了 云消息队列 Kafka 版 支持的退款情况。根据计费方式的特点，云消息队列 Kafka 版 资源支持的退款情况如下：包年包月的 云消息队列 Kafka 版 资源如需退款，可在控制台上退订实例。详细信息，请参见 实例生命周期管理。按小时后...
本文为您介绍 云消息队列 RocketMQ 版 的实例类型、计费方式、计费组成等信息。云消息队列 RocketMQ 版5.x系列 5.x系列计费概述 云消息队列 RocketMQ 版4.x系列 4.x系列计费概述
您可以在 云消息队列 Kafka 版 控制台创建实例、进行消息收发。云消息队列 Kafka 版 V3系列Serverless实例管理 V2系列实例管理 Topic Group Connector生态集成 迁移 权限管理 云消息队列 Confluent 版 集群资源规格评估 实例管理 权限管理 ...
本文介绍 轻量消息队列（原 MNS）作为函数的触发器或者将函数结果输出到队列或主题的功能说明和操作指南。作为函数的触发器 功能说明 将 轻量消息队列（原 MNS）的队列或主题当作触发函数执行的事件源。当消息产生时，如果满足触发器定义的...
针对各种业务需求，云消息队列 RocketMQ 版 提供相关的实践教程，您可以根据实例版本选择对应的最佳实践教程进行参考。云消息队列 RocketMQ 版5.x系列 5.x系列最佳实践 云消息队列 RocketMQ 版4.x系列 4.x系列最佳实践
本文介绍 云消息队列 RabbitMQ 版 的产品功能动态及对应的文档。2025-11-13 功能名称 功能描述 功能类型 相关文档 版本管理 Serverless系列独享实例支持版本管理（可自定义实例版本升级发布规则）新增 实例类型 版本管理 2025-10-31 功能...
部署架构图 选用的产品 云消息队列 Kafka 版 云消息队列 Kafka 版 是阿里云基于Apache Kafka构建的高吞吐量、高可扩展性的分布式消息队列服务，广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等，是大数据生态中不可或缺的...
本文介绍 云消息队列 Kafka 版 实例到期欠费后的影响，建议您提前续费，避免影响业务运行。欠费影响 如果您购买的为包年包月实例，实例到期后，您账户下的 云消息队列 Kafka 版 服务会切换为 已过期 状态，即您将不能再继续使用 云消息队列...
本文介绍 云消息队列 RocketMQ 版 中消费者（Consumer）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 消费者是 云消息队列 RocketMQ 版 中用来接收并处理消息的运行实体。消费者通常被集成在业务系统中，从 云消息...
本产品（消息队列 RabbitMQ 版/2019-12-12）的OpenAPI采用 RPC 签名风格，签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用...
背景信息 在订阅不可用的情况下，为保障整体服务可用性，轻量消息队列（原 MNS）会使用推送退避算法调整向下游订阅方推送消息的速度和数量。根据连续推送失败的次数，对推送间隔时间和单次推送最大条数进行调整：推送间隔时间：从0逐步扩大...
当往Kafka Topic中写入数据提示磁盘空间已满或 Queue full 时，为避免因磁盘容量不足而导致机器宕机，进而影响服务可用性，云消息队列 Kafka 版 会根据磁盘使用率的多少，执行不同的消息清理策略。清理策略 不同版本实例、不同类型Topic的...
注意事项 云消息队列 MQTT 版 的存储依赖于 云消息队列 RocketMQ 版，您在使用 云消息队列 MQTT 版 时，同时会收取 云消息队列 RocketMQ 版 的Topic资源占用费及API接口的调用费。因此，您的 阿里云产品消费汇总 中，会出现 云消息队列 ...
云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时，云消息队列 RocketMQ 版 仅4.0系列实例支持消息流入或流出规则，5.0系列实例不支持。...
本文旨在以简单明了的方式引导您快速上手 云消息队列 Kafka 版。操作流程 根据网络类型不同，快速入门的操作流程有所不同，详情请参见 云消息队列 Kafka 版快速入门操作流程。图 1.云消息队列 Kafka 版 快速入门操作流程 操作步骤 具体操作...
微消息队列MQTT版权限管理是通过阿里云的访问控制RAM（Resource Access Management）产品实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKeyId和AccessKeySecret），按需为用户分配最小权限。在使用RAM账号...
云消息队列 Kafka 版 提供全托管免运维服务，您无需登录机器。云消息队列 Kafka 版 是全托管的，由 云消息队列 Kafka 版 专业团队进行运维保障，您无需登录机器。集群的一些基础信息会通过监控告警进行透传。
云消息队列 MQTT 版 权限管理是通过阿里云的访问控制RAM（Resource Access Management）实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKey ID和AccessKey Secret），按需为用户分配最小权限。本文介绍 云...
轻量消息队列（原 MNS）处于欠费状态超过7天将停止服务。轻量消息队列（原 MNS）的欠费说明如下：轻量消息队列（原 MNS）服务费用的计费周期为小时，即阿里云将在下一小时对您上一小时的服务使用进行计量、出具账单并从您的阿里云账户中按...
在阿里云官方网站开通消息队列服务后方可开始使用 云消息队列 RocketMQ 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的 云消息队列 RocketMQ 版 资源，并使用资源通过SDK收发消息。前提条件 您已注册...
按量付费、Serverless实例欠费说明 云消息队列 RocketMQ 版 按量付费和Serverless实例以小时为计费周期，即 云消息队列 RocketMQ 版 将在每小时开始时刻计算您上一小时的费用，并从您的阿里云账户中按账单金额扣除服务费用。具体出账时间以...
本文介绍 轻量消息队列（原 MNS）的典型使用场景。典型的使用场景如下：将 轻量消息队列（原 MNS）与其他阿里云产品集成，让应用程序更加可靠、灵活。将 轻量消息队列（原 MNS）用作工作队列，其中每条消息代表一项任务，需要通过一个流程...
使用 云消息队列 RocketMQ 版 进行消息收发，您需要创建Group ID用于标识同一类生产者实例或者同一类消费者实例。本文介绍如何在 云消息队列 RocketMQ 版 控制台上创建、删除和查询Group。使用限制 单实例下最多创建1000个Group，建议您...
本文介绍如何使用 轻量消息队列（原 MNS）。注册阿里云账号并开通 轻量消息队列（原 MNS）服务。登录 账号管理，在左侧导航栏单击 概览，在 我的账号 卡片中获取账号ID。登录 用户信息管理，在左侧导航栏单击 安全信息管理，在 安全信息...
包年包月实例欠费说明 包年包月实例到期后状态变化如下：实例到期后，阿里云将暂停为您提供 云消息队列 MQTT 版 服务，实例和资源数据为您暂时保留。若您在停服后7天内未完成续费，云消息队列 MQTT 版 实例将被释放。释放后，实例及相关...
订阅者最佳实践 客户端首次接入云消息队列 Kafka 版时出现异常的排查方法 为什么消费客户端频繁出现Rebalance？消费端从服务端拉取不到消息或拉取消息缓慢 为什么不推荐使用Sarama Go客户端收发消息？使用云消息队列 Kafka 版时出现消息...
本文为您介绍 云消息队列 Kafka 版 实例的常见问题。实例支持哪些开源版本？VPC实例和公网/VPC实例的区别是什么？如何选择实例规格？如何获取部署实例时需要的VPC信息？升级Broker可能产生哪些影响？实例的地域无法变更 云消息队列 Kafka ...
云消息队列 MQTT 版广泛应用移动互联网以及物联网领域，覆盖互动直播、车联网、金融支付、智能餐饮、即时聊天、移动App等多种应用场景。
本文介绍通过 轻量消息队列（原 MNS）获取IMM任务状态及异步任务的执行状态的功能说明和操作指南。异步任务处理 功能说明 智能媒体管理 IMM（Intelligent Media Management）支持多种数据输出，其中有些处理时间会比较长，无法在一次同步...
在阿里云官方网站开通消息队列服务后方可开始使用 云消息队列 MQTT 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的 云消息队列 MQTT 版 资源，并使用SDK收发消息。前提条件 您已注册阿里云账号并完成...
云消息队列 RocketMQ 版（原名开放消息服务，简称ONS）是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式消息中间件。
包年包月实例欠费说明 包年包月实例到期后状态变化如下：实例到期后，阿里云将暂停为您提供 云消息队列 MQTT 版 服务，实例和资源数据为您暂时保留。若您在停服后7天内未完成续费，云消息队列 MQTT 版 实例将被释放。释放后，实例及相关...
概述 本文主要介绍客户端首次接入云消息队列 Kafka 版时，出现异常的排查方法。详细信息 客户端首次接入云消息队列 Kafka 版时如果出现异常，您可以通过以下三个方面进行排查：网络连通问题：通常有如下几种情况可能会导致网络不通，客户端...
对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版 不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...
云消息队列 MQTT 版 支持使用多种语言的SDK接入服务端实现消息收发，本文以Java为例介绍不同场景下的消息收发流程。操作流程 使用SDK收发消息流程如下图所示。具体操作步骤如下：开通服务并授权 开通消息队列服务，并授予RAM用户操作 云...
本文介绍 轻量消息队列（原 MNS）通过事件通知实时处理OSS文件变动的功能说明和操作指南。通过事件通知实时处理OSS文件变动 功能说明 当您需要对 对象存储 OSS（Object Storage Service）中的文件变动进行实时处理、同步、监听、业务触发、...
本文介绍 轻量消息队列（原 MNS）如何处理较长时间没有任何消息的队列。在您正常使用服务期间，阿里云 轻量消息队列（原 MNS）不会对不可见的队列或主题进行删除操作。但是，如果您的 轻量消息队列（原 MNS）使用权限因为欠费或其他原因被...
本文介绍 云消息队列 MQTT 版 提供的云端SDK和管控SDK的使用场景。使用说明 使用 云消息队列 MQTT 版 的云端SDK收发消息时，需要和终端SDK搭配使用。例如，使用云端SDK发送消息，终端SDK接收消息；或使用终端SDK发送消息，云端SDK接收消息...