本文通过 事件总线（EventBridge）将事件流实时路由到云消息队列RocketMQ（位点重置），以实现事件驱动架构下的消息分发与消费管理。前提条件 开通事件总线EventBridge并授权。创建 云消息队列RocketMQ 5.x系列实例 或 云消息队列RocketMQ ...
在创建并部署 云消息队列 Kafka 版 实例后，您可以使用 云消息队列 Kafka 版 控制台直接发送消息，快速测试服务端是否正常。前提条件 您已创建并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。操作流程 快速测试 云消息队列 ...
工作流集群 支持集成阿里云 轻量消息队列（原 MNS），利用 轻量消息队列（原 MNS）作为中介接入丰富的事件源，利用事件驱动触发工作流运行。当有新的事件触发（如OSS事件触发、EventBridge事件触发）时，轻量消息队列（原 MNS）会收到相应...
本文介绍了如何使用任务步骤的等待回调（waitForCallback）模式集成 轻量消息队列（原 MNS）主题，并发布消息到主题。轻量消息队列（原 MNS）主题接收到消息后，调用工作流ReportTaskSucceeded或ReportTaskFailed API回调任务状态。框架...
使用多可用区的消息队列 RocketMQ 5.0 版实例，视为“合规”。应用场景 通过多可用区部署，确保即使某个可用区出现故障，消息处理仍能高效稳定运行，保障业务连续性。此设置适用于需要高可用性和容错能力的系统架构中。风险等级 默认风险...
本文介绍 轻量消息队列（原 MNS）是否可以与其他阿里云产品协作使用的问题。轻量消息队列（原 MNS）可以与ECS、OSS和OTS等阿里云服务一起使用，从而让应用程序具有更好的灵活性和可扩展性。常见的使用案例如：创建需要互相通信却又不能同时...
本文介绍 轻量消息队列（原 MNS）如何处理较长时间没有任何消息的队列。在您正常使用服务期间，阿里云 轻量消息队列（原 MNS）不会对不可见的队列或主题进行删除操作。但是，如果您的 轻量消息队列（原 MNS）使用权限因为欠费或其他原因被...
本文介绍 云消息队列 RocketMQ 版 使用自定义权限策略的场景和策略示例。什么是自定义权限策略 在基于RAM的访问控制体系中，自定义权限策略是指在系统权限策略之外，您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您...
一、适用场景 本方案适用于 自建 RocketMQ 迁移至 阿里云消息队列 RocketMQ 场景。迁移类型适用于：元数据迁移、消息切 流。二、阿里云消息队列 RocketMQ 对比自建 RocketMQ 的优势 对比项 阿里云 RocketMQ 自建 RocketMQ 存储弹性 无资源...
云消息队列 Kafka 版 已与操作审计服务集成，您可以在操作审计中查询操作 云消息队列 Kafka 版 产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中，满足实时审计、问题回溯分析等需求。事件...
消息队列RocketMQ 5.0已与操作审计服务集成，您可以在操作审计中查询用户操作消息队列RocketMQ 5.0产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中，满足实时审计、问题回溯分析等需求。操作...
轻量消息队列（原 MNS）日志推送到日志服务后，可进行实时查询，本文介绍实时查询的常用场景及操作步骤，您也可以通过多个关键字组合方式实现更加复杂的查询。前提条件 已采集 轻量消息队列（原 MNS）日志。具体操作，请参见 轻量消息队列...
本文介绍如何使用DataWorks数据同步功能，将 云消息队列 Kafka 版 集群上的数据迁移至阿里云大数据计算服务MaxCompute，方便您对离线数据进行分析加工。背景信息 大数据计算服务MaxCompute（原ODPS）是一种大数据计算服务，能提供快速、...
解决方案 不同问题原因的解决方案不同，详情如下：原因一 如果使用 轻量消息队列（原 MNS）的SDK，请检查程序代码中的Endpoint值是否正确。正确的Endpoint地址获取方法如下：说明 常见错误是在代码中将Endpoint错写成队列地址，导致报错。...
本文介绍 云消息队列 Kafka 版 使用自定义权限策略的场景和策略示例。什么是自定义权限策略 在基于RAM的访问控制体系中，自定义权限策略是指在系统权限策略之外，您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您来...
使用 轻量消息队列（原 MNS）集成相比通过函数计算的函数发送消息到 轻量消息队列（原 MNS）的做法有以下好处：轻量消息队列（原 MNS）队列。轻量消息队列（原 MNS）队列进一步简化编排自定义任务类型。无需为发送消息做函数计算的函数的...
云消息队列 RocketMQ 版 所提供的TCP Java SDK支持多线程消费，且适用于所有消息类型，本文介绍如何设置消费线程数的方法。在启动Consumer时，设置一个ConsumeThreadNums属性即可。具体示例如下所示。public static void main(String[]args...
本文描述轻量消息队列（原 MNS）支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制...
消息队列RocketMQ版已与操作审计服务集成，您可以在操作审计中查询用户操作消息队列RocketMQ版产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中，满足实时审计、问题回溯分析等需求。操作审计...
本文介绍 云消息队列 RocketMQ 版 使用自定义权限策略的场景和策略示例。什么是自定义权限策略 在基于RAM的访问控制体系中，自定义权限策略是指在系统权限策略之外，您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您...
概述 本文主要介绍 轻量消息队列（原 MNS）中HttpEndpoint接口接收不到消息时的排查方法。排查步骤 请参考如下步骤进行排查。使用 主题HTTP Endpoint本地调试工具 进行调试，检查HttpEndpoint接口接收消息的逻辑是否存在问题。使用该工具可...
通过数据传输服务DTS（Data Transmission Service），您可以将自建MySQL同步至 云消息队列 Kafka 版，扩展消息处理能力。前提条件 您已完成以下操作：自建MySQL数据库且数据库版本为5.1、5.5、5.6、5.7或8.0版本。购买并部署 云消息队列 ...
本教程介绍如何使用Kafka Connect的Source Connector将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Kafka Connect主要用于将数据流输入和输出 云消息队列 Kafka 版。Kafka Connect主要通过各种Source Connector的实现，将数据从第三...
本文为您介绍 云消息队列 RocketMQ 版 连接器。重要 鉴于 云消息队列 RocketMQ 版 4.x标准版实例共享API调用弹性上限为每秒5000次，使用该版本的消息中间件在与实时计算Flink版对接时，若超过上限会触发限流机制，可能会导致Flink作业运行...
您可以通过PDS管理控制台配置事件通知规则，当这些PDS接口中对资源操作发生指定事件时，您可以通过 轻量消息队列（原 MNS）指定的接收终端，及时收到指定的事件通知。场景描述 某企业在华东1（杭州）地域创建了名为xxxx的域，该企业期望...
数据传输服务DTS（Data Transmission Service）支持将MySQL数据库（例如自建MySQL或 RDS MySQL）的数据同步至 云消息队列 RocketMQ 版 实例。本文以源库为 RDS MySQL 实例，为您介绍相关操作步骤。前提条件 已创建非Serverless系列的目标 ...
本文介绍如何通过 事件总线EventBridge 将消息队列RocketMQ版的数据推送到函数计算。前提条件 您已完成以下操作：事件总线EventBridge 开通事件总线EventBridge并授权 创建自定义总线 函数计算 创建函数 创建日志项目和日志仓库 SLS触发器 ...
本文为您介绍如何使用数据传输服务DTS（Data Transmission Service）将 PolarDB MySQL版 集群的数据同步至 云消息队列 RocketMQ 版 实例。说明 此功能正在灰度内测中，仅部分用户可以使用。前提条件 已创建非Serverless系列的目标 云消息...
数据传输服务DTS（Data Transmission Service）支持将MySQL数据库（例如自建MySQL或 RDS MySQL）的数据迁移至 云消息队列 RocketMQ 版 实例。本文以源库为 RDS MySQL 实例，为您介绍相关操作步骤。前提条件 已创建非Serverless系列的目标 ...
本文为您介绍如何使用数据传输服务DTS（Data Transmission Service）将 PolarDB MySQL版 集群的数据迁移至 云消息队列 RocketMQ 版 实例。说明 此功能正在灰度内测中，仅部分用户可以使用。前提条件 已创建非Serverless系列的目标 云消息...
步骤四：接收消息 当触发了事件匹配规则时，轻量消息队列将自动创建主题（Topic），Topic名称格式为 mns-en-topics-[Product]-[RuleName]-[Timestamp]，例如 mns-en-topics-oss-notification1-1700098799。此时，您需要为该Topic创建订阅，...
通过数据传输服务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实例...
本文介绍 云消息队列 RabbitMQ 版 使用自定义权限策略的场景和策略示例。什么是自定义权限策略 在基于RAM的访问控制体系中，自定义权限策略是指在系统权限策略之外，您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您...
本文介绍如何使用数据传输服务DTS（Data Transmission Service），将 PolarDB PostgreSQL版（兼容Oracle）集群的数据迁移至 阿里云消息队列Kafka版。前提条件 源 PolarDB PostgreSQL版（兼容Oracle）集群中 wal_level 参数的值需设置为 ...
本文介绍如何使用数据传输服务DTS（Data Transmission Service），将 PolarDB PostgreSQL版（兼容Oracle）集群的数据同步至 阿里云消息队列Kafka版。前提条件 源 PolarDB PostgreSQL版（兼容Oracle）集群中 wal_level 参数的值需设置为 ...
本文介绍如何删除某个队列的所有消息。您可以使用Java客户端库中 queuePurge 方法删除某个队列的所有消息。示例代码如下：channel.queuePurge("queue-name");
轻量消息队列（原 MNS）的队列（Queue）作为事件源通过 事件总线EventBridge 与 函数计算 集成后，通 轻量消息队列（原 MNS）队列触发器能够触发关联函数执行，通过函数可以对发布到 轻量消息队列（原 MNS）队列中的消息进行自定义处理。...
在使用云消息队列 Kafka 版时，客户端可能报错，您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权（sasl.mechanisms）...
在使用云消息队列 Kafka 版时，客户端可能报错，您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权（sasl.mechanisms）...
轻量消息队列（原 MNS）的主题（Topic）可以作为事件源通过 事件总线EventBridge 与 函数计算 进行集成。通过 轻量消息队列（原 MNS）主题触发器，当有新消息发送到您的 轻量消息队列（原 MNS）主题时，它会自动触发与之关联的函数执行，...