本文将向您介绍如何使用 云消息队列 Confluent 版 的Cluster Linking。主要包括如何远程使用Confluent CLI客户端方式创建Cluster Linking以及Cluster Linking的基本管理。前提条件 已经准备好数据源集群和数据目标集群。已经准备好用于连接...
背景信息 您可以在 云消息队列 Kafka 版 控制台 创建数据同步任务，将 云消息队列 Kafka 版 Topic中的数据同步至日志服务的日志库中。该同步任务将依赖阿里云 事件总线EventBridge 实现，具体为 事件总线EventBridge 中的事件流。更多信息...
开通消息检索相当于自动化创建了一个 云消息队列 Kafka 版 同步数据至 表格存储 的Connector任务，任务名称格式为：ots-ms-{Topic名称}-{6位随机字符}。任务详情查看操作，请参见 查看消息检索任务详情。首次开通消息检索后，云消息队列 ...
创建MaxCompute Sink Connector依赖的 Group 您可以在 云消息队列 Kafka 版 控制台手动创建MaxCompute Sink Connector数据同步任务使用的 Group。该 Group 的名称必须为connect-任务名称，具体信息，请参见 配置源服务参数列表。登录 云...
创建FC Sink Connector依赖的Group 您可以在 云消息队列 Kafka 版 控制台手动创建FC Sink Connector数据同步任务使用的 Group。该 Group 的名称必须为connect-任务名称，具体信息，请参见 配置源服务参数列表。登录 云消息队列 Kafka 版 ...
生效范围 在 云消息队列 MQTT 版 控制台创建的Topic仅会在 云消息队列 MQTT 版 生效，不会同步至 云消息队列 RocketMQ 版。同理，云消息队列 RocketMQ 版 控制台创建的Topic也不会同步至 云消息队列 MQTT 版。说明 调用OpenAPI的生效范围...
云消息队列 Kafka 版 提供全托管、免运维的迁移上云服务，用于自建集群或跨云云实例与 云消息队列 Kafka 版 实例之间的数据同步，迁移完成后可以把源集群的元数据（Topic和Group配置信息）和消息数据同步到目标实例，目标实例的元数据与源...
云消息队列 RocketMQ 版 支持同步传输和异步传输。更多信息，请参见 消息传输模式。事务行为：云消息队列 RocketMQ 版 支持事务消息，对于事务消息需要生产者配合进行事务检查等行为保障事务的最终一致性。具体信息，请参见 事务消息。生产...
云消息队列 MQTT 版 提供同步查询和异步上下线事件通知两种方式，来获取MQTT客户端在线状态。本文介绍这两种方式的基本原理、应用场景、具体差异以及实现方式。基本原理 云消息队列 MQTT 版 服务端（下文简称为MQTT服务端）提供以下方式...
本文说明如何为 云消息...后续步骤 为 云消息队列 Kafka 版 实例开启Connector后，您可以创建Connector将 云消息队列 Kafka 版 实例的数据同步到函数计算或大数据计算服务MaxCompute。创建FC Sink Connector 创建MaxCompute Sink Connector
本文介绍如何使用DataWorks数据同步功能，将 云消息队列 Kafka 版 集群上的数据迁移至阿里云大数据计算服务MaxCompute，方便您对离线数据进行分析加工。背景信息 大数据计算服务MaxCompute（原ODPS）是一种大数据计算服务，能提供快速、...
5.0-rmq-20240923-1 2024-09-03 实例系列 功能名称 功能描述 变更类型 相关文档 4.x系列实例 5.x系列实例 Global Replicator Global Replicator为客户提供分布在同一个国家内多个地域的多个 云消息队列 RocketMQ 版 实例之间消息同步的能力...
5.0-rmq-20240923-1 2024-09-03 实例系列 功能名称 功能描述 变更类型 相关文档 4.x系列实例 5.x系列实例 Global Replicator Global Replicator为客户提供分布在同一个国家内多个地域的多个 云消息队列 RocketMQ 版 实例之间消息同步的能力...
步骤三：迁移元数据 云消息队列 RocketMQ 版 读取自建集群的Topic和Group元数据信息，并同步复制到目标 云消息队列 RocketMQ 版 实例上。步骤四：更换接入点 确认此次迁移范围内的所有生产者以及消费者，将源集群消息收发代码中的接入点...
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台，面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。前置概念 阅读...
新增 使用限制 计费规则 欠费说明 2022-05-20 功能名称 功能描述 功能类型 相关文档 迁移路由 支持自建实例与 云消息队列 Kafka 版 实例之间或者 云消息队列 Kafka 版 实例之间的数据同步。新增 迁移路由 2022-04-18 功能名称 功能描述 ...
元数据迁移：通过读取源自建RocketMQ集群的元数据信息，并复制到目标阿里云 云消息队列 RocketMQ 版 集群中，实现元数据的创建和同步。消息迁移：通过 云消息队列 RocketMQ 版 自带的路由控制组件后台代理Topic路由信息，实现对客户端读写...
云消息队列 RabbitMQ 版是阿里云消息队列（MQ）团队基于AMQP 0-9-1协议研发的分布式、高吞吐、低延迟、高可扩展的云消息队列服务。消息队列RabbitMQ版完全兼容开源RabbitMQ社区、开箱即用、无需部署、免运维，帮助您快速上云。
Connector 云消息队列 Kafka 版 的组件，用于 云消息队列 Kafka 版 和其他阿里云服务之间的数据同步。更多信息，请参见 Connector概述。标签 用于识别 云消息队列 Kafka 版 资源。您可以将作用相同的 云消息队列 Kafka 版 的资源归类，便于...
云消息队列 MQTT 版广泛应用移动互联网以及物联网领域，覆盖互动直播、车联网、金融支付、智能餐饮、即时聊天、移动App等多种应用场景。
云消息队列 Kafka 版（ApsaraMQ for Kafka）秉持开放的原则拥抱开源，全面融合Kafka开源生态，做到无缝迁移，打造更安全、更可靠、更易运维的Kafka企业级消息服务。
云消息队列 RocketMQ 版（原名开放消息服务，简称ONS）是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式消息中间件。
阿里云轻量消息队列（原 MNS）（Simple Message Queue(formerly MNS)）是一种高效、可靠、安全、便捷、可弹性扩展的分布式消息服务。SMQ能够帮助应用开发者在他们应用的分布式组件上自由的传递数据、通知消息，构建松耦合系统。
集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...
本文介绍如何创建OSS Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至对象存储OSS。前提条件 在导出数据前，请确保您已完成以下操作：为 云消息队列 Kafka 版 实例开启Connector。更多信息，请参见 开启Connector。为...
创建AnalyticDB Sink Connector依赖的 Group 您可以在 云消息队列 Kafka 版 控制台手动创建AnalyticDB Sink Connector数据同步任务使用的 Group。该 Group 的名称必须为connect-任务名称，具体信息，请参见 配置源服务参数列表。登录 云...
当您需要将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至阿里云Elasticsearch的索引，您可以通过Elasticsearch Sink Connector实现。本文介绍如何创建Elasticsearch Sink Connector。前提条件 在导出数据前，请确保您已完成以下操作...
本文介绍在 轻量消息队列（原 MNS）控制台上可以执行的队列模型相关操作。前提条件 开通轻量消息队列（原 MNS）并授权。创建队列 登录 轻量消息队列（原 MNS）控制台。在左侧导航栏，选择 队列模型 队列列表。在顶部菜单栏，选择地域。在 ...
队列的主要作用如下：存储顺序性 队列天然具备顺序性，即消息按照进入队列的顺序写入存储，同一队列间的消息天然存在顺序关系，队列头部为最早写入的消息，队列尾部为最新写入的消息。消息在队列中的位置和消息之间的顺序通过位点（Offset...
如果您想创建一个只有自己可见的队列，不允许其他用户访问，您可以使用 云消息队列 RabbitMQ 版 的排他性队列特性，将指定的队列声明为排他性。什么是排他队列 排他性队列的特点如下：排他队列只对首次声明它的连接（Connection）可见，...
本文为您介绍如何在 轻量消息队列（原 MNS）控制台上快速上手使用队列模型。前提条件 开通轻量消息队列（原 MNS）并授权 创建队列 登录 轻量消息队列（原 MNS）控制台。在左侧导航栏，选择 队列模型 队列列表。在顶部菜单栏，选择地域。在 ...
轻量消息队列（原 MNS）的死信队列用于存储被消费者否定应答或重试失败的消息，方便您进行异常消息处理和问题定位。死信策略 死信状态 当消息消费次数达到最大接收次数后还没有被成功消费，消息将转为死信状态，保存在死信队列。死信消息...
云消息队列 MQTT 版 旧版本 强依赖 云消息队列 RocketMQ 版 作为消息存储，因此 云消息队列 MQTT 版 消息和 云消息队列 RocketMQ 版 天然打通，创建了Topic后即可天然使用 云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的SDK相互通信。...
本文对 轻量消息队列（原 MNS）的队列模型涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用队列模型。Account 用户的阿里云账号ID。队列（Queue）消息存储的目的地，分成普通队列和延时队列两类。消息包含数据和属性，...
云消息队列 MQTT 版 升级后实现了自身数据存储的能力，同时还去除了对 云消息队列 RocketMQ 版 的消息依赖，因此，云消息队列 MQTT 版 的实例和Topic使用有变更。资源 旧版本 使用说明 新版本 使用说明 云消息队列 MQTT 版 实例 旧版本 云...
映射关系如下：轻量消息队列（原 MNS）默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$....
映射关系如下：轻量消息队列（原 MNS）默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$....
映射关系如下：轻量消息队列（原 MNS）默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$....
轻量消息队列（原 MNS）支持使用队列模型和主题模型收发消息，实现一对一或者一对多的消费模式，本文以简单明了的方式让您快速上手 轻量消息队列（原 MNS）。背景信息 轻量消息队列（原 MNS）提供队列模型和主题模型。队列模型：支持一对一...
映射关系如下：轻量消息队列（原 MNS）默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$....