通过数据传输服务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...
本文介绍如何创建Debezium PostgreSQL Source Connector，将PostgreSQL的数据同步至 云消息队列 Kafka 版。使用限制 Debezium PostgreSQL Source Connector只能配置一个Task用于消费源端的CDC数据，不支持并发消费配置。前提条件 开通事件...
本教程介绍如何使用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）将 PolarDB MySQL版 集群的数据同步至 云消息队列 RocketMQ 版 实例。说明 此功能正在灰度内测中，仅部分用户可以使用。前提条件 已创建非Serverless系列的目标 云消息...
本文介绍如何创建Debezium MySQL Source Connector，将MySQL的数据同步至 云消息队列 Kafka 版。前提条件 已开通事件总线EventBridge并授权。已开通对象存储OSS服务并创建存储空间（Bucket）。更多信息，请参见 控制台创建存储空间。已开通...
数据传输服务DTS（Data Transmission Service）支持将MySQL数据库（例如自建MySQL或 RDS MySQL）的数据同步至 云消息队列 RocketMQ 版 实例。本文以源库为 RDS MySQL 实例，为您介绍相关操作步骤。前提条件 已创建非Serverless系列的目标 ...
通过数据传输服务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实例...
数据传输服务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版。说明 源库和目标库支持的版本，请参见 同步方案概览。自建...
本文介绍如何使用数据传输服务DTS（Data Transmission Service），将 PolarDB MySQL版 集群同步至 阿里云消息队列Kafka版，扩展消息处理能力。前提条件 已创建目标 阿里云消息队列Kafka版 实例，详情请参见 概述。说明 源库和目标库支持的...
数据传输服务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版 实例。创建方法，请参见 ...
云消息队列 Kafka 版 提供全托管、免运维的Connector，用于 云消息队列 Kafka 版 和其他阿里云服务之间的数据同步。本文介绍Connector支持的数据同步任务的类型、使用流程、使用限制以及跨地域数据同步。重要 云消息队列 Kafka 版 的...
云消息队列 Kafka 版 提供全托管、免运维的实例迁移服务，支持把自建Kafka集群的元数据（Topic和Group配置信息）和消息数据同步到 云消息队列 Kafka 版 实例，迁移完成后 云消息队列 Kafka 版 实例的元数据与自建Kafka集群的元数据保持一致...
Global Replicator同步消息数据会占用 云消息队列 RocketMQ 版 源实例的读性能、目标实例的写性能，您需要额外评估 云消息队列 RocketMQ 版 的 产品计费。支持的地域和版本 地域：覆盖 云消息队列 RocketMQ 版 已开服的地域，具体请参见 源...
背景信息 您可以在 云消息队列 Kafka 版 控制台 创建数据同步任务，将日志服务的日志库中的数据同步至 云消息队列 Kafka 版 的Topic中。该同步任务将依赖阿里云 事件总线EventBridge 实现，具体为 事件总线EventBridge 中的事件流。更多...
Global Replicator同步消息数据会占用 云消息队列 RocketMQ 版 源实例的读性能，目标实例的写性能，您需要额外评估 云消息队列 RocketMQ 版 的计算规格。Global Replicator认证模式配置ACL后，为什么没有收到同步的消息？Global Replicator...
背景信息 您可以在 云消息队列 Kafka 版 控制台 创建数据同步任务，将您在阿里云数据库RDS MySQL版数据库表中的数据同步至 云消息队列 Kafka 版 的Topic。该同步任务将依赖阿里云DataWorks产品实现，流程图如下所示。如果您在 云消息队列 ...
本文介绍如何通过创建Tablestore Sink Connector，将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至表格存储（Tablestore）。前提条件 云消息队列 Kafka 版 已为实例开启Connector。具体操作，请参见 开启Connector。已为实例创建...
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
本文为您介绍通过数据传输服务DTS（Data Transmission Service）服务将MySQL数据库（例如自建MySQL、RDS MySQL或PolarDB MySQL）的数据同步至 云消息队列 RocketMQ 版。前提条件 已创建非Serverless系列的目标 云消息队列 RocketMQ 版 实例...
本文介绍如何在 云消息队列 MQTT 版 控制台创建流出目标为 云消息队列 RocketMQ 版 的消息流出任务。前提条件 您已购买 云消息队列 MQTT 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。开通事件总线EventBridge并授权。...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务，实现将 云消息队列 RocketMQ 版 指定实例的数据流入至另外的 云消息队列 RocketMQ 版 实例。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建流入任务，将指定 云消息队列 RabbitMQ 版 实例中的数据快速导入至另外的 云消息队列 RabbitMQ 版 实例中。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。...
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务，将指定 云消息队列 Kafka 版 实例中的数据快速导入至另外的 云消息队列 Kafka 版 实例中。前提条件 您已购买 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请...
云消息队列 RocketMQ 版 Global Replicator支持消费进度同步功能，本文为您介绍消费进度同步的操作步骤。单向同步任务 注意事项 消费进度同步功能开启后，如果选择自动更新消费进度，则每10秒会对实例间所有Topic映射关系下的同名Group进行...
云消息队列 RocketMQ 版 Global Replicator支持对数据同步任务的流入、流出和处理量等指标进行统计。此外，系统支持监控指标的云监控报警配置，当指标达到报警阈值时，将向报警接收人发出相应的报警通知。背景信息 云消息队列 RocketMQ 版 ...
为加强网络信息安全管理，提高数据安全性，全球消息路由功能不支持跨境及跨国传输，具体规则如下：中国内地的各地域之间可以同步消息，中国内地不支持和中国香港及海外地区的所有地域同步消息。中国香港地域仅支持在本地域内同步消息，不...
阿里云 云消息队列 RocketMQ 版 提供三种方式来发送普通消息：同步发送、异步发送和单向（Oneway）发送。本文介绍了每种发送方式的原理、使用场景、示例代码，以及三种发送方式的对比；此外还提供了订阅普通消息的示例代码。前提条件 您已...
云消息队列 RocketMQ 版 支持将指定实例的Topic列表信息导出，再导入至其他的 云消息队列 RocketMQ 版 实例，实现Topic的跨实例迁移。您可以在更换实例或者克隆实例时，使用Topic导入/导出功能快速批量创建出相同的Topic。背景信息 云消息...
生效范围 在 云消息队列 MQTT 版 控制台创建的Topic仅会在 云消息队列 MQTT 版 生效，不会同步至 云消息队列 RocketMQ 版。同理，云消息队列 RocketMQ 版 控制台创建的Topic也不会同步至 云消息队列 MQTT 版。说明 调用OpenAPI的生效范围...
当 云消息队列 Kafka 版 控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时，您可以使用 云消息队列 Kafka 版 消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...
背景信息 您可以在 云消息队列 Kafka 版 控制台 创建数据同步任务，将 云消息队列 Kafka 版 Topic中的数据同步至日志服务的日志库中。该同步任务将依赖阿里云 事件总线EventBridge 实现，具体为 事件总线EventBridge 中的事件流。更多信息...