您可以通过basicReject或basicNack方法否定应答消息，使消息重入队列，从而是其他Consumer可以消费消息。使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。...
本教程介绍如何使用Kafka Connect的Source Connector将SQL Server的数据同步至 云消息队列 Kafka 版。前提条件 在开始本教程前，请确保您已完成以下操作：已下载SQL Server Source Connector。具体信息，请参见 SQL Server Source ...
您可以通过basicReject或basicNack方法否定应答消息，使消息重入队列，从而是其他Consumer可以消费消息。使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。...
本教程介绍如何使用Canal将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Canal的主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。Canal伪装自己为MySQL Slave，向MySQL Master发送dump请求。MySQL Master收到dump...
本文介绍如何在 事件总线EventBridge 控制台添加 云消息队列 RocketMQ 版 作为事件流中的事件提供方。前提条件 开通事件总线EventBridge并授权。您已购买并部署 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 ...
您可以通过事件规则过滤事件，将事件路由到 消息队列RocketMQ版。本文以自定义事件为例介绍将事件路由到 消息队列RocketMQ版 的前提条件、操作步骤和结果验证。前提条件 事件总线EventBridge 开通事件总线EventBridge并授权 消息队列...
本文介绍如何在 事件总线EventBridge 控制台添加 云消息队列 RocketMQ 版（位点数据）作为事件流中的事件提供方。前提条件 开通事件总线EventBridge并授权。创建 云消息队列RocketMQ 5.x系列实例 或 云消息队列RocketMQ 4.x系列实例。创建...
事件总线EventBridge 支持接入 云消息队列 RocketMQ 版 的消息，进行事件分析、查看事件轨迹、进行数据转发等操作。本文介绍如何在 事件总线EventBridge 控制台添加 云消息队列 RocketMQ 版 类型的自定义事件源。前提条件 云消息队列 ...
本文为您介绍使用C++ SDK接入 云消息队列 RocketMQ 版 所需完成的准备工作、使用说明以及注意事项，以便后续使用C++ SDK收发消息。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x...
本文为您介绍使用v1.x.x版本的C++ SDK接入 云消息队列 RocketMQ 版 所需完成的准备工作、使用说明以及注意事项，以便后续使用C++ SDK收发消息。使用前，请注意以下几点：本文仅针对C++ SDK v1.x.x版本进行说明。代码里涉及到的Topic和Group...
Apache RocketMQ C++ 5.0系列SDK底层基于gRPC，本文为您介绍如何使用源码编译RocketMQ C++ Client。前提条件 安装GCC 为了确保与gRPC保持相同的兼容性矩阵，编译环境需满足以下要求：编译最低需要C++ 11环境，对应GCC版本最低为4.8.5，推荐...
云消息队列 RocketMQ 版 提供C/C++ SDK实现消息发送与订阅，您可通过本文了解消息发送和订阅相关接口的参数说明。参数名 参数说明 NAMESRV_ADDR 设置TCP协议接入点，从 云消息队列 RocketMQ 版 控制台的 实例详情 页面获取。AccessKey ...
本文介绍如何在 Serverless 应用引擎 SAE（Serverless App Engine）上基于阿里云 云消息队列 RocketMQ 版 实现环境隔离，您可以在不修改任何业务代码的情况下，实现异步场景下的流量控制。背景信息 支持RocketMQ版本：4.2.0及以上版本。...
本文介绍如何使用DataWorks数据同步功能，将 云消息队列 Kafka 版 集群上的数据迁移至阿里云大数据计算服务MaxCompute，便于分析加工离线数据。前提条件 在开始本教程前，确保您在同一地域中已完成以下操作：云消息队列 Kafka 版 购买并...
推荐版本 云消息队列 RocketMQ 版 5.x版本实例完全兼容Apache RocketMQ C++ SDK，以下版本经过阿里云工程师进行测试验证，建议您使用以下SDK版本进行消息收发。具体推荐版本：rocketmq-client-cpp-5.0.3 重要 当前版本不支持通过公网访问 ...
本文介绍如何通过 云消息队列 RocketMQ 版 的C/C++ SDK订阅消息。订阅方式 云消息队列 RocketMQ 版 支持以下两种订阅方式：集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息，一个Group ID有3个...
本文介绍如何使用数据传输服务DTS（Data Transmission Service），将自建Oracle迁移至阿里云消息队列Kafka。前提条件 已创建源数据库自建Oracle和目标实例 阿里云消息队列Kafka版。说明 源库和目标库支持的版本，请参见 迁移方案概览。自建...
通过数据传输服务DTS（Data Transmission Service），您可以将自建Oracle迁移至阿里云消息队列Kafka版或自建Kafka，从而扩展消息处理能力。本文以自建Oracle数据库迁移至阿里云消息队列Kafka实例为例，介绍数据迁移任务的配置流程。前提...
本文介绍如何使用数据传输服务DTS（Data Transmission Service），将自建Oracle同步至阿里云消息队列Kafka。前提条件 已创建源数据库自建Oracle和目标实例 阿里云消息队列Kafka版。说明 源库和目标库支持的版本，请参见 同步方案概览。自建...
本文介绍您在使用社区版C++ SDK接入阿里云 云消息队列 RocketMQ 版 时，需要配置的参数。通用参数 参数名 说明 NameServer 设置TCP协议接入点，从 控制台 的 实例详情 页面获取。GroupID 您在 控制台 上创建的Group ID，更多信息，请参见 ...
通过消息队列这类异步场景下的流量控制，您可以在不需要修改任何业务代码的情况下，实现全链路灰度。本文介绍MSE基于消息队列RocketMQ版实现全链路灰度。前提条件 开通MSE微服务治理。创建ACK托管集群。Demo架构 本文以容器服务控制台部署...
数据传输服务DTS（Data Transmission Service）支持 AnalyticDB PostgreSQL版 实例同步至 阿里云消息队列Kafka版。说明 当前功能目前正处于邀测阶段。如您有相关需求，请 提交工单 与我们联系，以便为您开启该功能。适用范围 目标实例 阿里...
使用C++ SDK接入阿里云 云消息队列 RocketMQ 版 收发消息前，您需按本文提供的操作步骤安装CPP动态库。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更...
云消息队列 RocketMQ 版 5.x版本实例支持C++ 1.x SDK客户端接入，您可以使用1.x版本的SDK接入5.x实例进行消息收发。本文为您介绍1.x版本下的C++ SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发...
在使用社区版C++ SDK接入阿里云 云消息队列 RocketMQ 版 来收发消息前，您需按本文提供的操作步骤安装CPP动态库。前提条件 在开始做准备工作前，请确保您的操作系统满足以下条件：Linux：CentOS 6.8、CentOS 7.2、RHEL 6.x、RHEL 7.x ...
本文提供使用TCP协议下的C/C++ SDK收发事务消息的示例代码供您参考。云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图...
绝大多数情况下，消息是不重复的。作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，无法保证消息不重复，但是能保证消息不丢失。
本文提供使用TCP协议下的社区版C++ SDK来收发事务消息的示例代码供您参考。阿里云 云消息队列 RocketMQ 版 提供类似X/Open XA的分布式事务功能，通过阿里云 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。交互流程 事务...
顺序消息FIFO（First In First Out）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的C/C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，...
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格...
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的C++ SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。更...
背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息。定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端...
本文主要介绍如何使用RocketMQ 4.x/3.x系列的rocketmq-client-cpp二进制包进行部署和连接阿里云 云消息队列 RocketMQ 版 的过程。如需源码编译，请您自行前往开源社区下载。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力...
顺序消息（FIFO消息）是阿里云 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的社区版C++ SDK收发顺序消息的示例代码供您参考。顺序消息分为两类：全局顺序：对于指定的一个Topic，所有...
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的C++ SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装C++ SDK。更多信息，请参见 准备环境...
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。不同消息类型所属的Topic不能混用，例如收发普通消息的Topic不能用来收发其他类型的消息。本文提供使用TCP协议下的C/C++ SDK收发...
普通消息是指阿里云 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时消息、顺序消息和事务消息。本文提供使用TCP协议下的社区版C++ SDK收发普通消息的示例代码供您参考。前提条件 安装CPP动态库 获取阿里云访问密钥AccessKey ...
本文提供使用TCP协议下的社区版C++ SDK来收发定时和延时消息的示例代码供您参考。背景信息 定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是推迟到在当前时间点之后的某一个时间投递到...
本文为您介绍RocketMQ 5.x系列C++ SDK的消息收发示例代码。消息类型 发送消息示例代码 订阅消息示例代码 PushConsumer SimpleConsumer 普通消息 同步发送：ExampleProducer.cpp 异步发送：ExampleProducerWithAsync.cpp ...
本文提供使用TCP协议下的C/C++ SDK收发定时消息的示例代码供您参考。定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对消息生产和消费有时间窗口要求，或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意...