通过数据传输服务DTS（Data Transmission Service），您可以将自建MySQL同步至 云消息队列 Kafka 版，扩展消息处理能力。前提条件 您已完成以下操作：自建MySQL数据库且数据库版本为5.1、5.5、5.6、5.7或8.0版本。购买并部署 云消息队列 ...
本教程介绍如何使用Canal将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Canal的主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。Canal伪装自己为MySQL Slave，向MySQL Master发送dump请求。MySQL Master收到dump...
本文为您介绍如何使用数据传输服务DTS（Data Transmission Service）将 PolarDB MySQL版 集群的数据同步至 云消息队列 RocketMQ 版 实例。说明 此功能正在灰度内测中，仅部分用户可以使用。前提条件 已创建非Serverless系列的目标 云消息...
本教程介绍如何使用Kafka Connect的Source Connector将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Kafka Connect主要用于将数据流输入和输出 云消息队列 Kafka 版。Kafka Connect主要通过各种Source Connector的实现，将数据从第三...
本教程介绍如何使用Kafka Connect的Source Connector将SQL Server的数据同步至 云消息队列 Kafka 版。前提条件 在开始本教程前，请确保您已完成以下操作：已下载SQL Server Source Connector。具体信息，请参见 SQL Server Source ...
通过数据传输服务DTS（Data Transmission Service），您可以将自建MySQL同步至消息队列Kafka版，扩展消息处理能力。前提条件 自建MySQL的数据库版本为5.1、5.5、5.6、5.7或8.0版本。目标Kafka实例的版本为0.10.1.0-2.x版本。目标Kafka实例...
本文介绍如何创建Debezium PostgreSQL Source Connector，将PostgreSQL的数据同步至 云消息队列 Kafka 版。使用限制 Debezium PostgreSQL Source Connector只能配置一个Task用于消费源端的CDC数据，不支持并发消费配置。前提条件 开通事件...
数据传输服务DTS（Data Transmission Service）支持 RDS MySQL 实例同步至 阿里云消息队列Kafka版。前提条件 已创建源实例 RDS MySQL 和目标实例 阿里云消息队列Kafka版。说明 源实例 RDS MySQL 的创建方式，请参见 创建RDS MySQL实例。源...
数据传输服务DTS（Data Transmission Service）支持 RDS MySQL 实例同步至 阿里云消息队列Kafka版。前提条件 已创建源实例 RDS MySQL 和目标实例 阿里云消息队列Kafka版。说明 源实例 RDS MySQL 的创建方式，请参见 创建RDS MySQL实例。源...
本文介绍如何使用数据传输服务DTS（Data Transmission Service），将自建Oracle同步至阿里云消息队列Kafka。前提条件 已创建源数据库自建Oracle和目标实例 阿里云消息队列Kafka版。说明 源库和目标库支持的版本，请参见 同步方案概览。自建...
本文介绍如何创建Debezium MySQL Source Connector，将MySQL的数据同步至 云消息队列 Kafka 版。前提条件 已开通事件总线EventBridge并授权。已开通对象存储OSS服务并创建存储空间（Bucket）。更多信息，请参见 控制台创建存储空间。已开通...
本文介绍如何使用数据传输服务DTS（Data Transmission Service），将 PolarDB MySQL版 集群同步至 阿里云消息队列Kafka版，扩展消息处理能力。前提条件 已创建目标 阿里云消息队列Kafka版 实例，详情请参见 概述。说明 源库和目标库支持的...
数据传输服务DTS（Data Transmission Service）支持将MySQL数据库（例如自建MySQL或 RDS MySQL）的数据同步至 云消息队列 RocketMQ 版 实例。本文以源库为 RDS MySQL 实例，为您介绍相关操作步骤。前提条件 已创建非Serverless系列的目标 ...
数据传输服务DTS（Data Transmission Service）支持 AnalyticDB PostgreSQL版 实例同步至 阿里云消息队列Kafka版。说明 当前功能目前正处于邀测阶段。如您有相关需求，请 提交工单 与我们联系，以便为您开启该功能。适用范围 目标实例 阿里...
本文介绍如何使用数据传输服务DTS（Data Transmission Service），将 PolarDB PostgreSQL版（兼容Oracle）集群的数据同步至 阿里云消息队列Kafka版。前提条件 源 PolarDB PostgreSQL版（兼容Oracle）集群中 wal_level 参数的值需设置为 ...
本文介绍如何使用数据传输服务DTS（Data Transmission Service）将PolarDB-X 1.0同步至阿里云消息队列Kafka。前提条件 已创建Kafka实例，并已创建用于接收同步数据的Topic，请参见 概述。说明 源库和目标库支持的版本，请参见 同步方案概览...
本文介绍如何使用数据传输服务DTS（Data Transmission Service），将 PolarDB-X 2.0 同步至阿里云消息队列Kafka，实现增量数据的实时同步。前提条件 已创建源 PolarDB-X 2.0 实例。已创建存储空间大于源 PolarDB-X 2.0 实例已占用存储空间...
本文以 云数据库MongoDB版（副本集架构）实例为源库，且以 阿里云消息队列Kafka版 实例为目标库，为您介绍同步操作的步骤。前提条件 已创建目标 阿里云消息队列Kafka版 实例。说明 源库和目标库支持的版本，请参见 同步方案概览。已在目标 ...
本文以 云数据库Tair（兼容Redis）实例为源库，且以 阿里云消息队列Kafka版 实例为目标库，为您介绍同步操作的步骤。重要 此功能正在灰度内测中，仅部分用户可以使用。前提条件 已创建目标 阿里云消息队列Kafka版 实例。创建方法，请参见 ...
迁移步骤说明 从SQS和SNS迁移数据到 轻量消息队列（原 MNS）时，为确保您的业务平滑过渡，建议您首先同步队列、主题和订阅的元数据，然后业务侧做双读双写策略过渡。下图以SQS数据迁移到 轻量消息队列（原 MNS）为例，介绍迁移的过程。具体...
创建Tablestore Sink Connector依赖的 Group 您可以在 云消息队列 Kafka 版 控制台手动创建Tablestore Sink Connector数据同步任务使用的 Group。该 Group 的名称必须为connect-任务名称，具体信息，请参见 配置源服务参数列表。登录 云...
云消息队列 Kafka 版 提供全托管、免运维的实例迁移服务，支持把自建Kafka集群的元数据（Topic和Group配置信息）和消息数据同步到 云消息队列 Kafka 版 实例，迁移完成后 云消息队列 Kafka 版 实例的元数据与自建Kafka集群的元数据保持一致...
云消息队列 Kafka 版 提供全托管、免运维的Connector，用于 云消息队列 Kafka 版 和其他阿里云服务之间的数据同步。本文介绍Connector支持的数据同步任务的类型、使用流程、使用限制以及跨地域数据同步。重要 云消息队列 Kafka 版 的...
背景信息 您可以在 云消息队列 Kafka 版 控制台 创建数据同步任务，将日志服务的日志库中的数据同步至 云消息队列 Kafka 版 的Topic中。该同步任务将依赖阿里云 事件总线EventBridge 实现，具体为 事件总线EventBridge 中的事件流。更多...
云消息队列 RocketMQ 版 支持Global Replicator功能，能够实现跨地域及跨实例的消息和消费进度同步。本文将介绍Global Replicator特性等信息。功能简介 Global Replicator为您提供跨地域、跨实例的消息和消费进度同步能力，支持开源和商业...
Global Replicator同步消息数据会占用 云消息队列 RocketMQ 版 源实例的读性能，目标实例的写性能，您需要额外评估 云消息队列 RocketMQ 版 的计算规格。Global Replicator认证模式配置ACL后，为什么没有收到同步的消息？Global Replicator...
背景信息 您可以在 云消息队列 Kafka 版 控制台 创建数据同步任务，将您在阿里云数据库RDS MySQL版数据库表中的数据同步至 云消息队列 Kafka 版 的Topic。该同步任务将依赖阿里云DataWorks产品实现，流程图如下所示。如果您在 云消息队列 ...
本文为您介绍通过数据传输服务DTS（Data Transmission Service）服务将MySQL数据库（例如自建MySQL、RDS MySQL或PolarDB MySQL）的数据同步至 云消息队列 RocketMQ 版。前提条件 已创建非Serverless系列的目标 云消息队列 RocketMQ 版 实例...
如上图所示，Canal将自己伪装成库，监听并接收数据库的Binlog，并同步到 云消息队列 RocketMQ 版 等存储或其他中间件系统。具体操作步骤如下：配置MySQL：开启MySQL的Binlog功能，创建测试需要的数据库和表。部署Canal：部署一个canal-...
云消息队列 RocketMQ 版 Global Replicator支持消费进度同步功能，本文为您介绍消费进度同步的操作步骤。单向同步任务 注意事项 消费进度同步功能开启后，如果选择自动更新消费进度，则每10秒会对实例间所有Topic映射关系下的同名Group进行...
云消息队列 RocketMQ 版 Global Replicator支持对数据同步任务的流入、流出和处理量等指标进行统计。此外，系统支持监控指标的云监控报警配置，当指标达到报警阈值时，将向报警接收人发出相应的报警通知。背景信息 云消息队列 RocketMQ 版 ...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建流入任务，将指定 云消息队列 RabbitMQ 版 实例中的数据快速导入至另外的 云消息队列 RabbitMQ 版 实例中。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。...
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务，将指定 云消息队列 Kafka 版 实例中的数据快速导入至另外的 云消息队列 Kafka 版 实例中。前提条件 您已购买 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务，实现将 云消息队列 RocketMQ 版 指定实例的数据流入至另外的 云消息队列 RocketMQ 版 实例。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。...
本文介绍如何在 云消息队列 MQTT 版 控制台创建流出目标为 云消息队列 RocketMQ 版 的消息流出任务。前提条件 您已购买 云消息队列 MQTT 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。开通事件总线EventBridge并授权。...
同步消费进度信息到目标实例。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action ...
查询消费进度同步列表。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action 元素中...
阿里云 云消息队列 RocketMQ 版 提供三种方式来发送普通消息：同步发送、异步发送和单向（Oneway）发送。本文介绍了每种发送方式的原理、使用场景、示例代码，以及三种发送方式的对比；此外还提供了订阅普通消息的示例代码。前提条件 您已...
什么是全球消息路由 云消息队列 RocketMQ 版 的全球消息路由功能依托阿里云优质基础设施实现的高速通道专线（高速通道无需另行开通），高效地实现不同地域之间的消息同步复制。具体实现如下图所示。计费影响 全球消息路由为 云消息队列 ...
云消息队列 RocketMQ 版 支持将指定实例的Topic列表信息导出，再导入至其他的 云消息队列 RocketMQ 版 实例，实现Topic的跨实例迁移。您可以在更换实例或者克隆实例时，使用Topic导入/导出功能快速批量创建出相同的Topic。背景信息 云消息...