应用场景
与传统架构不同，云消息队列 Kafka 版 以及Storm、Samza、Spark等数据处理引擎的出现，就是为了更好地解决这类数据在处理过程中遇到的问题，数据处理模型能实现在数据流动的过程中对数据进行实时地捕捉和处理，并根据业务需求进行计算分析...
基本概念
本文介绍 云消息队列 RocketMQ 版 的基本概念，以便您更好地理解和使用 云消息队列 RocketMQ 版。主题（Topic）云消息队列 RocketMQ 版 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题通过TopicName来做唯一标识和区分。...
作为Input接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
作为Input接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
作为Input接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
作为Output接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
作为Output接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
作为Output接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
作为Input接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
生产者负载均衡
在极端场景下，可能会出现大部分消息集中在少数队列中的情况，建议设计消息组时尽量将消息离散开，不要集中在少量消息组中。使用示例 MessageGroupHash模式不需要额外设置，对于顺序消息类型默认启用。顺序消息发送，默认采用...
查看消费状态
有消息堆积就一定是出现问题了吗？不一定。一般分为以下三种情况：最近消费时间与当前时间接近，并且堆积量保持在一个稳定的数值之间波动，没有持续扩大。说明客户端一直在拉取最新消息，没有消息堆积，属于正常情况。堆积量逐步扩大，并且...
作为Output接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
常见问题
本文介绍与 事件总线EventBridge 相关的基本问题。什么是 事件总线...事件总线EventBridge 支持的阿里云产品的事件格式，请参见 企业级分布式应用服务事件。如何配置事件模式过滤事件？关于如何配置事件模式，请参见 管理事件规则。
集群消费和广播消费
由于消费者应用一般是分布式系统，以集群方式部署，因此消息队列约定以下概念：集群：使用相同 Group ID 的消费者属于同一个集群。同一个集群下的消费者消费逻辑必须完全一致（包括 Tag 的使用）。详情请参见 订阅关系一致。集群消费：当...
基本概念
但是会出现部分分区发送消息失败的情况，等到宕机机器重新上线后即可恢复正常。更多信息，请参见 存储引擎对比。Connector 云消息队列 Kafka 版 的组件，用于 云消息队列 Kafka 版 和其他阿里云服务之间的数据同步。更多信息，请参见 ...
基本概念
事务消息 云消息队列 RocketMQ 版 提供类似XA或Open XA的分布事务功能，通过 云消息队列 RocketMQ 版 的事务消息能达到分布式事务的最终一致。更多信息，请参见 事务消息。顺序消息 云消息队列 RocketMQ 版 提供的一种按照顺序进行发布和...
使用云消息队列 Kafka 版时出现“Not authorized to ...
问题描述 使用云消息队列 Kafka 版时出现“Not authorized to access group”的错误信息。问题原因 没有创建Consumer Group时会遇到此报错信息。解决方案 您可以选择如下任意一种方式创建Consumer Group。在云消息队列 Kafka 版的控制台...
概述
分布式事务 DTX（Distributed Transaction-eXtended）是蚂蚁集团自主研发的金融级分布式事务中间件，用来保障在大规模分布式环境下业务活动的最终一致性。在蚂蚁集团内部被广泛地应用于交易、转账、红包等核心资金链路，服务于亿级用户的...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图所示。更多信息，请参见 事务消息。前提条件 您已完成以下操作：下载C...
分布式序列问题
分布式序列是否全局唯一 单库单表的分布式序列可以保证生成的序列 ID 全局唯一。分库分表的分布式序列仅保证单个分片的序列 ID 唯一，如果需要确保分库分表的分布式序列全局唯一，可以在序列 ID 中拼接分库分表位，以此保证全局唯一。分布...
基础术语
事务消息 Transactional message 消息队列提供类似 X/Open XA 的分布事务功能，通过消息队列的事务消息能达到分布式事务的最终一致。详情请参见 事务消息。顺序消息 Ordered message 消息队列提供的一种按照顺序进行发布和消费的消息类型，...
升级实例配置
注意事项 升级实例配置会引发集群逐台重启，可能会出现如下风险：客户端会短暂断开连接并重连，可能会造成少量报错。已经发送成功的消息，升级之后不会丢失。升级期间发送失败的消息，建议重试发送，可在客户端配置重试机制。升级预计持续...
阿里云官方事件源
事件总线EventBridge 支持将阿里云官方事件作为事件源发布到事件总线，事件总线EventBridge 作为统一的入口来处理、分发这些事件。本文介绍 事件总线EventBridge 支持的阿里云官方事件源对应的阿里云服务和云服务事件类型。事件类型 阿里...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图所示。更多信息，请参见 事务消息。前提条件 下载.NET SDK。更多信息...
延时消息
因为 云消息队列 RabbitMQ 版 的消息是分布式存储的，如果您使用pull模式的 basic.get 方法获取消息，并不能保证正好从存储的节点获取消息。常见问题 为什么实际的延时时间大于设置的延时时间？因为客户端使用了pull模式的basic.get方法...
从自建MySQL同步至云消息队列 Kafka 版
背景信息 云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务，针对开源的Apache Kafka提供全托管服务，彻底解决开源产品长期以来的痛点，您只需专注于业务开发，无需部署运维。云消息队列 Kafka 版 广泛用于日志...
消费者负载均衡
策略特点 相对于队列粒度负载均衡策略，消息粒度负载均衡策略有以下特点：消费分摊更均衡 传统队列级的负载均衡策略中，如果队列数量和消费者数量不均衡，则可能会出现部分消费者空闲，或部分消费者处理过多消息的情况。消息粒度负载均衡...
基础术语
发起方 initiator 分布式事务的发起方负责启动分布式事务，通过调用参与者的服务，将参与者纳入到分布式事务当中，并决定整个分布式事务是提交还是回滚。一个分布式事务有且只能有一个发起方。参与者 participant 参与者提供分支事务服务。...
功能特性
数据访问代理兼容 MySQL 协议和语法，支持分库分表、平滑扩容、服务升降配、透明读写分离和分布式事务等特性，具备分布式数据库全生命周期的运维管控能力。分库分表 支持 RDS、OceanBase、MySQL 的分库分表。在创建分布式数据库后，只需...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的PHP SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。更...
将云消息队列 Kafka 版的数据迁移至MaxCompute
MaxCompute和DataWorks一起向用户提供完善的数据处理和数仓管理能力，以及SQL、MR、Graph等多种经典的分布式计算模型，能够更快速地解决用户海量数据计算问题，有效降低企业成本，保障数据安全。本教程旨在帮助您使用DataWorks，将 云消息...
组件中心
中间件 分布式链路跟踪 一款实时监控并管理企业应用性能和故障的云服务，其提供数字化性能管理解决方案，帮助企业在分布式架构下快速发现并准确定位应用全生命周期的性能问题。任务调度 提供分布式任务调度框架，实现任务的分布式处理，并...
消息过滤
可能原因：若多个消费者是通过同一个消费者分组（Group ID）订阅的指定Topic，则所有消费者的过滤条件即订阅的Tag要一致，否则会出现订阅关系不一致，导致部分消息丢失。消费者设置了过滤条件，消息消费数量是按照过滤前还是过滤后计算呢？...
消息收发常见问题
本文介绍使用 云消息队列 MQTT 版 进行消息收发时的常见问题。为什么会出现一条消息同一时间重试多次？为什么消息会一直重试？消息发送时提示GroupID没有权限。使用RocketMQ数据流入MQTT功能时，为什么子级Topic后会多了一个“/”?消息发送...
配额与限制
云消息队列 RocketMQ 版 对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值，避免应用出现异常。参数限制 以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...
消息堆积和延迟问题
本文主要介绍 云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中，经常会出现的消息堆积和消息延迟的问题。通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或...
MQTT快速入门
在以下使用情况中出现的问题 云消息队列 MQTT 版 产品方概不负责：客户端不使用域名接入而是使用IP地址接入，产品方更新了域名解析导致原有IP地址失效。客户端网络对IP地址设置网络防火墙策略，产品方更新了域名解析后新IP地址被您的防火墙...
中间件产品总览
SOFABoot 基于 Spring Boot 自研的开发框架 集成 SOFA 中间件，且中间件可插拔 服务网格 将传统微服务和 Service Mesh 进行融合 对接经典应用服务和容器应用服务 提供丰富的服务治理功能 消息队列 基于 Apache RocketMQ 构建的分布式消息...
TCP协议客户端大版本发布
该策略可能会出现以下问题：消费者数量比和Queue数量多时，部分消费者获取不到消息的现象。部分消费者异常或者处理缓慢，其他消费者空闲却无法共同分担堆积压力的情况。以消息为粒度进行负载，负载策略更加均衡。避免了队列级负载策略可能...
产品优势
分布式中间件 蚂蚁分布式中间件的产品发展路径，一直秉承引领和拥抱业界先进标准和实践，同时亦能满足传统金融架构的平滑迁移、融合适配，以稳妥应对业务升级变更，并积极应对金融交易系统所面临的服务和数据扩展性、事务一致性、秒级容灾...
- 产品推荐
- 这些文档可能帮助您