作为Output接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
查看消费状态
当Kafka出现消费堆积、倾斜、流量被限流等异常时，您可以查看Group和Topic之间的订阅关系，获取Topic各个分区的消费进度，了解消息的堆积总量，及时调整业务、预防风险。注意事项 建议一个消费组不要订阅超过三个Topic，避免消息堆积。当您...
作为Output接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
API概览
本产品（微消息队列 MQTT/2020-04-20）的OpenAPI采用 RPC 签名风格，签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用需求...
消息堆积和延迟问题
本文主要介绍 云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中，经常会出现的消息堆积和消息延迟的问题。通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或...
作为Input接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
作为Output接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
事务消息
事务消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...
顺序消息
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...
将云消息队列 Kafka 版接入阿里云Elasticsearch
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
集群消费和广播消费
集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...
普通消息
普通消息为 云消息队列 RocketMQ 版 中最基础的消息，区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等...
定时/延时消息
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻...
自动创建Topic
自动创建Topic是指当 云消息队列 Kafka 版 实例发送请求以获取不存在的Topic元数据时，例如向不存在的Topic发送生产请求，云消息队列 Kafka 版 可以自动创建Topic。自动创建Topic适用于迁移上云场景或测试场景，无需手动重复创建Topic，...
快速使用MQTT的Java SDK收发消息（终端和终端消息收发...
在以下使用情况中出现的问题 云消息队列 MQTT 版 产品方概不负责：终端或云端不使用域名接入而是使用IP地址接入，产品方更新了域名解析导致原有IP地址失效。终端或云端网络侧对IP地址设置网络防火墙策略，产品方更新了域名解析后新IP地址被...
RocketMQ全链路追踪解决方案
在分布式应用系统中，多个服务间的交互涉及复杂的网络通信和数据传输，往往一次请求需要多个内部服务间的相互调用才能完成，任何一个环节出现问题都可能导致外部服务任务执行失败或延时，且很难快速定位问题根源。链路追踪功能可在多个服务...
新功能发布记录
本文介绍 云消息队列 Kafka 版 的产品功能动态及对应的文档。2024-04-15 功能名称 功能描述 功能类型 相关文档 V3.0 Serverless系列实例在华东2（上海）地域开服 云消息队列 Kafka 版 V3.0 Serverless系列实例支持在华东2（上海）地域选购...
监控数据相关问题
本文汇总了 云消息队列 Kafka 版 关于监控数据的相关问题。我需要关注哪些指标项？一般情况下，您只需关注以下指标项：实例消息生产流量 Topic消息生产流量 Group未消费消息总数 其他指标项（如实例/Topic消息生产条数、实例/Topic消息生产...
使用Canal和RocketMQ实现数据库变更订阅处理
false 链路轨迹追踪设置 使用Canal发送变更事件到 云消息队列 RocketMQ 版 时，可以选择开启 云消息队列 RocketMQ 版 的云上消息轨迹功能，以便出现异常时可以快速定位链路问题。开启链路轨迹追踪功能，需要设置如下参数：rocketmq.enable....
配额与限制
云消息队列 RocketMQ 版 对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值，避免应用出现异常。参数限制 以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...
使用Canal和RocketMQ实现数据库变更订阅处理
false 链路轨迹追踪设置 使用Canal发送变更事件到 云消息队列 RocketMQ 版 时，可以选择开启 云消息队列 RocketMQ 版 的云上消息轨迹功能，以便出现异常时可以快速定位链路问题。开启链路轨迹追踪功能，需要设置如下参数：rocketmq.enable....
异步任务完成通知
EventBridge 什么是事件总线EventBridge 事件总线EventBridge是阿里云提供的一款无服务器事件总线服务，支持阿里云服务、自定义应用、SaaS应用以标准化、中心化的方式接入，并能够以标准化的CloudEvents 1.0协议在这些应用之间路由事件，...
应用场景
与传统架构不同，云消息队列 Kafka 版 以及Storm、Samza、Spark等数据处理引擎的出现，就是为了更好地解决这类数据在处理过程中遇到的问题，数据处理模型能实现在数据流动的过程中对数据进行实时地捕捉和处理，并根据业务需求进行计算分析...
新零售电子价签解决方案（MQTT）
新零售电子价签解决方案由阿里云 云消息队列 MQTT 版 推出，通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项，其他类似行业可参考该方案...
迁移上云概述
和开源Apache RocketMQ相比，阿里云 云消息队列 RocketMQ 版 具有更高的稳定性、安全性及更完善的运维体系。您可以将开源RocketMQ集群迁移到 云消息队列 RocketMQ 版 上以获得更好的业务体验，本文为您介绍开源RocketMQ集群迁移上云的方案...
查看实例风险
云消息队列 Kafka 版 实例的实时诊断功能能够定期对实例进行检测，支持查看诊断发现的问题、提供修复建议，并将异常的检查项上报告警给相关联系人，帮助您及时处理异常。实现方案 检测项 说明 若检测出实例存在风险，请参考控制台上提示的...
查看实例风险
云消息队列 Kafka 版 实例的实时诊断功能能够定期对实例进行检测，支持查看诊断发现的问题、提供修复建议，并将异常的检查项上报告警给相关联系人。实现方案 报警通知说明 仅紧急且不健康的报警会发送报警通知。如果未添加报警联系人，则...
自动化创建Topic相关问题
本文汇总了 云消息队列 Kafka 版 关于自动创建Topic的相关问题。是否可以自动化创建Topic？可以，但不建议。云消息队列 Kafka 版 通过阿里云控制台和OpenAPI管理Topic数据，目前不支持也不建议自动化创建Topic，主要原因如下：自动化创建...
死信消息
消息消费异常时会自动进行消费重试，达到最大重试次数后还未成功，则消息会转为死信状态。云消息队列 RocketMQ 版 支持将这些死信消息保存至指定Topic，方便后续进行业务恢复或回溯。本文介绍死信消息的应用场景、死信策略、使用限制、配置...
延时消息
如果您希望消息被投递后延迟一段时间被消费者消费，您可以使用 云消息队列 RabbitMQ 版 的延时消息。云消息队列 RabbitMQ 版 原生支持延时消息，使用方式比开源RabbitMQ更简单。什么是延时消息 延时消息是指在指定时间段之后才被消费者消费...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图所示。更多信息，请参见 事务消息。前提条件 您已完成以下操作：下载C...
自动创建Topic
操作步骤 登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在 实例详情 页面的 配置信息 区域，打开 自动创建Topic 开关。说明 自动创建的Topic名称命名规则：长度限制为3...
基于IaC自动化部署事件总线
本文介绍如何应用IaC（Infrastructure as Code）理念自动化部署 事件总线EventBridge，帮助您解决大量云产品手工管理负担沉重的问题。背景信息 IaC是一种以代码来配置和管理虚拟机、网络等基础设施的实践方法。通过将基础设施代码化、版本...
升级实例版本
升级版本 登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在 实例详情 页面的 基础信息 区域，执行以下操作。升级大版本：单击 大版本 右侧的 开源版本升级。升级小版本...
4.x和5.x版本差异及兼容性说明
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云 云消息队列 RocketMQ 版 将为您提供更加稳定可靠的服务端5...
4.x和5.x版本差异及兼容性说明
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云 云消息队列 RocketMQ 版 将为您提供更加稳定可靠的服务端5...
Exactly-Once投递语义
本文主要介绍 云消息队列 RocketMQ 版 的Exactly-Once投递语义的概念和典型使用场景，以便您理解如何使得消息只被消费端处理且仅处理一次。什么是Exactly-Once投递语义 Exactly-Once是指发送到消息系统的消息只能被消费端处理且仅处理一次...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图所示。更多信息，请参见 事务消息。前提条件 下载.NET SDK。更多信息...
管理Kafka自定义连接器
登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。在左侧导航栏，选择 Connector生态集成>消息流入（Source）。在 消息流入（Source）页面，单击 创建任务。在 消息流入创建 面板中，完成以下配置，单击 确定。...
阿里云官方事件源
事件总线EventBridge 支持将阿里云官方事件作为事件源发布到事件总线，事件总线EventBridge 作为统一的入口来处理、分发这些事件。本文介绍 事件总线EventBridge 支持的阿里云官方事件源对应的阿里云服务和云服务事件类型。事件类型 阿里...
- 产品推荐
- 这些文档可能帮助您