RDS MySQL同步至阿里云消息队列Kafka版
若您部署的 阿里云消息队列Kafka版 的 版本 为 0.10.2，请选择 0.10。若您部署的 阿里云消息队列Kafka版 的 版本 为 2.6.2 或 2.2.0，请选择 1.0以上。连接方式 根据业务及安全需求，选择 非加密连接 或 SCRAM-SHA-256。Topic 在下拉框中...
RDS MySQL同步至阿里云消息队列Kafka版
若您部署的 阿里云消息队列Kafka版 的 版本 为 0.10.2，请选择 0.10。若您部署的 阿里云消息队列Kafka版 的 版本 为 2.6.2 或 2.2.0，请选择 1.0以上。连接方式 根据业务及安全需求，选择 非加密连接 或 SCRAM-SHA-256。Topic 在下拉框中...
PolarDB-X 1.0同步至阿里云消息队列Kafka
本文介绍如何使用数据传输服务DTS（Data Transmission Service）将PolarDB-X 1.0同步至阿里云消息队列Kafka。前提条件 已创建源PolarDB-X 1.0实例。具体操作，请参见 创建实例。已创建Kafka实例，并已创建用于接收同步数据的Topic，请参见 ...
自建Oracle同步至阿里云消息队列Kafka版
本文介绍如何使用数据传输服务DTS（Data Transmission Service），将自建Oracle同步至阿里云消息队列Kafka。前提条件 已创建源数据库自建Oracle和目标实例 阿里云消息队列Kafka版。说明 源数据库和目标实例支持的版本，请参见 同步方案概览...
PolarDB MySQL版同步至阿里云消息队列Kafka版
阿里云消息队列Kafka版，扩展消息处理能力。前提条件 已创建源 PolarDB MySQL版 集群，详情请参见 购买按量付费集群 和 购买包年包月集群 已创建目标 阿里云消息队列Kafka版 实例，详情请参见 概述。目标实例 阿里云消息队列Kafka版 中已...
将云消息队列 Kafka 版接入阿里云Elasticsearch
当您需要查看并分析庞杂的日志数据时，可通过阿里云Logstash将 云消息队列 Kafka 版 中的日志数据导入阿里云Elasticsearch，然后通过Kibana进行可视化展示与分析。本文介绍将 云消息队列 Kafka 版 接入阿里云Elasticsearch的操作方法。前提...
PolarDB-X 2.0同步至阿里云消息队列Kafka
同步至阿里云消息队列Kafka，实现增量数据的实时同步。前提条件 已创建源 PolarDB-X 2.0 实例，且兼容MySQL 5.7版本。目标Kafka实例的版本请参见 数据库版本。目标Kafka实例的存储空间须大于 PolarDB-X 2.0 数据库占用的存储空间。目标...
从自建Oracle迁移至阿里云消息队列Kafka
Service），您可以将自建Oracle迁移至阿里云消息队列Kafka版或自建Kafka，从而扩展消息处理能力。本文以自建Oracle数据库迁移至阿里云消息队列Kafka实例为例，介绍数据迁移任务的配置流程。前提条件 自建Oracle数据库的版本为9i、10g、11g...
自建Oracle迁移至阿里云消息队列Kafka版
本文介绍如何使用数据传输服务DTS（Data Transmission Service），将自建Oracle迁移至阿里云消息队列Kafka。前提条件 已创建源数据库自建Oracle和目标实例 阿里云消息队列Kafka版。说明 源数据库和目标实例支持的版本，请参见 迁移方案概览...
RDS MySQL迁移至阿里云消息队列Kafka版
本文介绍如何使用数据传输服务DTS（Data Transmission Service），将 RDS MySQL 迁移至 阿里云消息队列Kafka版。前提条件 已创建源实例 RDS MySQL 和目标实例 阿里云消息队列Kafka版。说明 源实例 RDS MySQL 的创建方式，请参见 快速创建...
从自建MySQL同步至阿里云消息队列Kafka版
通过数据传输服务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实例...
PolarDB-X 2.0迁移至阿里云消息队列Kafka
迁移至阿里云消息队列Kafka，从而扩展消息处理能力。前提条件 已创建源 PolarDB-X 2.0 实例，且需兼容MySQL 5.7版本。目标Kafka实例中已创建用于接收迁移数据的Topic，请参见 步骤一：创建Topic。源和目标实例支持的版本，请参见 数据库...
PolarDB-X 1.0迁移至阿里云消息队列Kafka
本文介绍如何使用数据传输服务DTS（Data Transmission Service）将PolarDB-X 1.0迁移至阿里云消息队列Kafka。前提条件 已创建源PolarDB-X 1.0实例。具体操作，请参见 创建实例。说明 PolarDB-X 1.0的存储类型支持为RDS MySQL（包括私有定制...
消息轨迹
您已向 云消息队列 RabbitMQ 版 发送消息，或已从 云消息队列 RabbitMQ 版 中消费消息。操作步骤 登录 云消息队列 RabbitMQ 版 控制台，然后在左侧导航栏选择 实例列表。在 实例列表 页面的顶部菜单栏选择地域，然后在实例列表中，单击目标...
消息类型
本文介绍 SOFAStack 消息队列各个消息类型的概念、适用场景以及使用过程中的注意事项等。普通消息 定时和延时消息 顺序消息 事务消息 普通消息 普通消息是指消息队列中无特性的消息，区别于有特性的定时/延时消息、顺序消息和事务消息。TCP...
配置消息队列Kafka版实例的参数
Kafka版本 若您部署的 阿里云消息队列Kafka版 的 版本 为 0.10.2，请选择 0.10。若您部署的 阿里云消息队列Kafka版 的 版本 为 2.6.2 或 2.2.0，请选择 1.0以上。请在 实例信息 页签的 基础信息 区域，查看 大版本。连接方式 若 阿里云消息...
消息路由
您可以登录消息队列控制台，根据业务需求创建跨地域的消息同步任务。操作步骤如下：登录 SOFAStack 控制台。在左侧导航栏，选择 中间件>消息队列 消息路由。单击 创建路由任务，然后在 创建路由任务 对话框配置任务信息：源 Topic：输入...
消息队列
集成消息队列 RocketMQ 说明 注意：集成阿里云消息队列Rocket MQ服务，需要您先参考安装云服务集成章节完成云服务集成的安装。登录 阿里云BaaS控制台。在 我的组织 中找到目标组织，单击右侧的 云服务集成。将云服务集成页面的标签切换到 ...
消息检索
当 云消息队列 Kafka 版 控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时，您可以使用 云消息队列 Kafka 版 消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...
消息队列 RocketMQ 客户端流控设计
本文以阿里云消息队列 RocketMQ 为例，介绍了如何使用 ACM 对消息队列 RocketMQ 实现流量控制。迁移到MSE Nacos ACM进入下线状态，所有配置管理相关的需求由MSE中的Nacos承接（ACM独享版，更好的安全和稳定性）。您需要在ACM控制台导出配置...
什么是云消息队列 RocketMQ 版？
为什么选择云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 基于阿里云云原生优质的基础设施实现，兼容Apache RocketMQ的核心API和功能。相对于自建RocketMQ集群，云消息队列 RocketMQ 版 具有如下优势：架构先进性 全面采用存储和计算分离...
普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。说明 您在调用SDK收发消息时需注意， 云消息队列 RocketMQ 版 提供的四种消息类型所对应的Topic不能混用，例如，您创建的普通...
事务消息
事务消息队列 消息存活时间小于消息延时时间。当消息发送成功、事务操作成功时，生产者修改消息延迟时间，消息对消费者可见。当消息发送成功、事务操作失败时，生产者不修改消息延迟时间，消息对消费者不可见。操作日志队列 记录事务消息的...
查询消息
云消息队列 Kafka 版 控制台支持按位点查询和按时间查询。背景信息 您可根据具体情况按以下推荐方式查询消息：如果您确定消息所在Topic的分区ID以及消息位点，则推荐您使用 按位点查询消息。位点的相关概念，请参见 基本概念 如果您不确定...
什么是云消息队列 MQTT 版
云消息队列 MQTT 版 是阿里云推出的一款面向移动互联网以及物联网领域的轻量级消息中间件。如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递和真正意义上的万物互联...
订阅消息
本文介绍如何通过 云消息队列 RocketMQ 版 的C/C++ SDK订阅消息。订阅方式 云消息队列 RocketMQ 版 支持以下两种订阅方式： 集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息，一个Group ID有3个...
什么是云消息队列 Kafka 版？
云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。产品优势 云消息队列 ...
云消息队列 Kafka 版服务等级协议
云消息队列 Kafka 版 规定了阿里云向客户提供的阿里云 云消息队列 Kafka 版 的服务可用性等级指标及赔偿方案。如需查看 云消息队列 Kafka 版 的服务可用性等级指标及赔偿方案，请参见 云消息队列 Kafka 版服务等级协议。
上行消息
该tag会用于mns消息队列名称的生成，多个tag即对应多个mns消息队列。查看服务端应用映射列表操作步骤：1.进入CMNS-上行消息页面。2.选择服务端应用，点击“映射列表”链接，打开映射列表页面。查看服务端应用映射列表操作步骤：1.进入CMNS-...
消息重试
本文介绍 SOFAStack 消息队列的消息重试机制和配置方式。顺序消息的重试 对于顺序消息，当消费者消费消息失败后，消息队列会自动不断地进行消息重试（每次间隔时间为 1 秒），这时，应用会出现消息消费被阻塞的情况。因此，建议您使用顺序...
消息队列
智能对话分析服务作为消息的生产者，通过向您的阿里云消息队列RocketMQ服务中发送消息的方式推送相关信息给您，您作为消息的消费者从RocketMQ中接收并消费消息，从而实现低延迟、高并发、高可用的消息推送。视频讲解 授权 需要您授权，允许...
消息队列指标
对消息队列的监控指标进行汇总。通过设置搜索指标，可以实现精准的信息汇总。通过回放和自动更新，可以简化监控信息的查看。主要操作如下：搜索设置 正则过滤 输入正则表达式，可以将图表里的 key，按照正则表达式进行过滤。例如：曲线名或...
消息负载均衡策略
消息队列的消息负载策略针对发布方和订阅方有所差异。对订阅方而言，消息负载策略在一定程度上影响消息堆积。发布方消息负载均衡策略 消息队列针对发布方采取的是轮询制，即 Producer 的消息以轮询的方式发送至 Queue，如下图所示。图中...
收发定时消息和延时消息
社区版的Apache RocketMQ和阿里云 云消息队列 RocketMQ 版 配置方式不同，实现效果也有所差异。社区版的Apache RocketMQ支持延时消息，但不支持定时消息，因此没有专门的定时消息接口。阿里云 云消息队列 RocketMQ 版 不仅同时支持配置延时...
顺序消息
什么是顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种对消息发送和消费顺序有严格要求的消息。对于一个指定的Topic，消息严格按照先进先出（FIFO）的原则进行消息发布和消费，即先发布的消息先消费，后发布的消息后消费。顺序消息...
查询消息
如果您对发送到 云消息队列 RabbitMQ 版 的消息有问题，您可以在 云消息队列 RabbitMQ 版 控制台查询消息。背景信息 云消息队列 RabbitMQ 版 支持以下查询方式：按Queue查询：适用于只知道消息发送到的Queue，不知道发送消息时设置的...
消息队列
更正文档 概述 消息队列是一种任务间传递数据的有效方式。消息队列使用环形缓冲池（ring buffer）来管理消息的队列缓冲区，并使用类似信号量的机制进行任务间的同步。任务通过消息队列可以发送消息，也可以通过它接收消息，从而实现数据的...
顺序消息
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...
收发普通消息
普通消息是指阿里云 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时消息、顺序消息和事务消息。本文提供使用TCP协议下的社区版C++ SDK收发普通消息的示例代码供您参考。前提条件 安装CPP动态库 获取阿里云访问密钥AccessKey ...
事务消息
云消息队列 RocketMQ 版 提供的分布式事务消息适用于所有对数据最终一致性有强需求的场景。本文介绍 云消息队列 RocketMQ 版 事务消息的概念、优势、典型场景、交互流程、使用规则以及示例代码。概念介绍 事务消息：云消息队列 RocketMQ 版...
- 产品推荐
- 这些文档可能帮助您