最新位点（latest）最早位点（earliest）最新位点（latest）网络配置 选择路由消息的网络类型。基础网络 自建公网 基础网络 专有网络VPC 选择VPC ID。当 网络配置 设置为 自建公网 时需要设置此参数。vpc-bp17fapfdj0dwzjkd*交换机 选择...
问题现象 Topic中有消息并且Consumer未消费到最新的位置，出现消费端从服务端拉取不到消息或拉取消息缓慢的情况（特别是公网消费时）。可能原因 可能的原因包括：消费流量达到网络带宽。单个消息大小超过网络带宽。Consumer每次拉取的消息...
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面地功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x系列SDK和ONS系列SDK后续仅做...
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流入任务，将 云消息队列 RocketMQ 版 的数据快速导入至 云消息队列 Kafka 版。前提条件 您已购买Kafka实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和部署实例。您已...
背景信息 云消息队列 Kafka 版 支持以下重置消费位点方式：从最新位点开始消费：不再消费Broker上堆积的消息，将消费位点重置到最新的位置。指定时间点开始消费：将消费位点重置到过去的某个时间点（该时间点以Topic的消息存储时间为准）。...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务，以实现将 云消息队列 RocketMQ 版 的数据快速导出至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务，以实现将 云消息队列 RocketMQ 版 的数据快速导出至 轻量消息队列（原 MNS）。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务，以实现将 云消息队列 RocketMQ 版 数据快速导入至 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务，以实现将 云消息队列 RocketMQ 版 指定实例的数据导入至另外的 云消息队列 RocketMQ 版 实例。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务，实现将 云消息队列 RocketMQ 版 指定实例的数据流入至另外的 云消息队列 RocketMQ 版 实例。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为函数计算的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已开通函数计算服务，具体操作，请参见 ...
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
当消费者出现故障或者消费错误数据时，您可通过重置消费位点将消费位置回滚到之前的某个位点重新开始消费，您也可以将消费位置移动至最新位点，暂时不处理堆积的消息。消息 API 标题 API概述 ListMessages 查询消息列表 查询消息列表。...
说明 若您采用RocketMQ集成Flink的方式进行消息收发，在迁移时建议使用最新版本的SDK（需要自行编译）。具体信息请参见 rocketmq-flink。迁移范围确认 云消息队列 RocketMQ 版 支持Topic级别的迁移粒度，能达到分批次、可灰度、可回滚的...
本文介绍如何创建Elasticsearch Sink Connector，您可以通过Elasticsearch Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至阿里云Elasticsearch中。前提条件 详细步骤，请参见 创建前提。步骤一：创建目标服务资源 在...
功能介绍 保留消息（Retained Message）是指客户端在某个主题上发布一条消息时，指定该消息被服务器保留，后续订阅该主题的新客户端都将立即接收到这条保留消息，而无需等待新的消息发布。使用限制 目前仅专业版和铂金版支持该功能，且需要...
可以使用以下格式的MQTT消息并设定过期时间，来确保只有最新状态被处理：PUBLISH Topic:factory/machine1/status Payload:RUNNING QoS:1 Message Expiry Interval:300/消息发布后保留5分钟（300秒）的有效期 如果这条消息在5分钟内没有被...
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
云消息队列 RabbitMQ 版 为您提供全托管的版本管理服务，服务端版本更新后，系统会在后台自动完成升级，您可以根据波峰谷时间修改后台升级的执行时间和可维护时间段。使用限制 仅Serverless独享实例支持版本管理功能。升级影响 升级期间...
当 云消息队列 Kafka 版 控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时，您可以使用 云消息队列 Kafka 版 消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...
云消息队列 RocketMQ 版 为您提供全托管的版本管理服务，服务端版本更新后，系统会在后台自动完成升级，不影响消息收发，业务侧无感知。您可以根据波峰谷时间修改后台升级的执行时间和可维护时间段。使用限制 仅铂金版实例支持版本管理功能...
ons-client-1.8.7.4.Final 说明 若您使用1.8.7.1.Final及之后版本的Java SDK消费顺序消息，建议您将SDK客户端升级到最新版本。1.8.4.Final 发布时间 发布内容 下载 2019-09-27 新特性 支持1.6 JDK。支持异步发送重试。支持同步发送...
ons-client-1.8.7.4.Final 说明 若您使用1.8.7.1.Final及之后版本的Java SDK消费顺序消息，建议您将SDK客户端升级到最新版本。1.8.4.Final 发布时间 发布内容 下载 2019-09-27 新特性 支持1.6 JDK。支持异步发送重试。支持同步发送...
步骤一：准备工作 下载最新版C#SDK，解压后将工程导入到VisualStudio。找到工程里四个项目中SDK所在的项目 AliyunSDK_MNS，右击项目名，选择重新生成，在 bin 目录下生成 Aliyun.MNS.dll。说明 其他几个项目里都需要引用 Aliyun.MNS.dll，...
Chat App 消息服务是阿里云为全球企业打造的一款高效触达用户的消息引擎，通过与WhatsApp平台合作，使您轻松地使用WhatsApp平台的消息服务，触达全球10亿+用户，通过丰富的消息类型，提升您与客户的互动体验，创造更大业务价值。
云消息队列 RabbitMQ 版是阿里云消息队列（MQ）团队基于AMQP 0-9-1协议研发的分布式、高吞吐、低延迟、高可扩展的云消息队列服务。消息队列RabbitMQ版完全兼容开源RabbitMQ社区、开箱即用、无需部署、免运维，帮助您快速上云。
云消息队列 RocketMQ 版（原名开放消息服务，简称ONS）是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式消息中间件。
阿里云轻量消息队列（原 MNS）（Simple Message Queue(formerly MNS)）是一种高效、可靠、安全、便捷、可弹性扩展的分布式消息服务。SMQ能够帮助应用开发者在他们应用的分布式组件上自由的传递数据、通知消息，构建松耦合系统。
云消息队列 Kafka 版（ApsaraMQ for Kafka）秉持开放的原则拥抱开源，全面融合Kafka开源生态，做到无缝迁移，打造更安全、更可靠、更易运维的Kafka企业级消息服务。
云消息队列 MQTT 版广泛应用移动互联网以及物联网领域，覆盖互动直播、车联网、金融支付、智能餐饮、即时聊天、移动App等多种应用场景。
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
客户端日志用于记录 云消息队列 RocketMQ 版 客户端运行过程中的异常，帮助您快速定位和修复问题。本文介绍如何为客户端开启日志打印功能、客户端日志的配置项说明以及如何自定义配置客户端日志。开启客户端日志打印功能 云消息队列 ...
本文介绍如何使用C#SDK创建队列、发送消息、接收和删除消息、以及删除队列。步骤一：准备工作 下载最新版C#SDK，解压后将工程导入到VisualStudio。找到工程里四个项目中SDK所在的项目 AliyunSDK_MNS，单击鼠标右键，选择重新生成，在 bin ...
在2019年01月23日，云消息队列 RocketMQ 版 优化了资源隔离、资源申请、协议支持以及权限管理。本文提供相关更新说明，帮助您更顺畅地使用 云消息队列 RocketMQ 版。说明 为兼容新老资源配置，建议您将ons-client客户端升级到最新版本。...