Connection和Channel
Connection数量较少而消费的数据量较大时，可能会出现消费倾斜问题，您可以在保证每个消费者Connection数一致的同时，增加每个消费者的Connection数或增加消费者数量。建议所有消费者的Connection之和大于30。多个进程可以共享同一个...
顺序消息
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...
常见问题
使用云消息队列 Kafka 版时客户端的报错及解决方案 无法ping通云消息队列 Kafka 版的接入点 客户端消费问题 订阅者最佳实践 客户端首次接入云消息队列 Kafka 版时出现异常的排查方法 使用云消息队列 Kafka 版时出现消息堆积 为什么消费客户...
开源对比
千级分区就会出现大量抖动。巡检系统 针对死锁、宕机等问题进行自动发现和修复。无。Bug修复 及时发现并修复。只能等社区缓慢修复，且通常要等新版发布，周期长。内核能力 项目 云消息队列 Kafka 版 Apache Kafka 弹性能力 秒级弹缩，业务...
顺序消息
如果是普通消息，订单A的消息可能会被轮询发送到不同的队列中，不同队列的消息将无法保持顺序，而顺序消息发送时 云消息队列 RocketMQ 版 支持将Sharding Key相同（例如同一订单号）的消息序路由到一个队列中。云消息队列 RocketMQ 版 服务...
使用限制
单实例消息收发TPS 根据购买的规格进行限流，云消息队列 MQTT 版 消息收发TPS超过规格上限后，客户端（包含开源MQTT客户端和云端SDK）可能会出现连接断开、响应超时和消息丢弃等情况，不保证消息可靠到达。在MQTT客户端场景下，单MQTT客户...
基本概念
但是会出现部分分区发送消息失败的情况，等到宕机机器重新上线后即可恢复正常。更多信息，请参见 存储引擎对比。Connector 云消息队列 Kafka 版 的组件，用于 云消息队列 Kafka 版 和其他阿里云服务之间的数据同步。更多信息，请参见 ...
步骤三：创建资源
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
功能特性
SOFAStack 消息队列在阿里云多个...当使用广播消费模式时，消息队列会将每条消息推送给消费者集群内所有注册过的消费者，保证消息至少被每台机器消费一次。重置消费位点：根据时间或位点重置消费进度，允许用户进行消息回溯或者丢弃堆积消息。
应用场景
消息的顺序收发 云消息队列 RocketMQ 版 顺序消息分为两种情况：全局顺序：对于指定的一个Topic，所有消息将按照严格的先入先出（FIFO）的顺序，进行顺序发布和顺序消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块...
作为Input接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
作为Input接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
作为Output接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
作为Input接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
作为Output接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
迁移上云操作
如果消费顺序的类型选择错误，会导致迁移后消息的消费顺序出现异常。如果您不确定Group的消费顺序，可以 提交工单 咨询。确认本次迁移任务内所有需要迁移的Topic和Group已经全部导入后，单击 导入完成，进入下一步。步骤四：更换接入点 ...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 联合 阿里云云监控 提供了开箱即用且免费的监控报警服务，可帮助您解决如下问题：实例规格水位监控预警 若您实际使用的指标值超过实例的规格限制，云消息队列 RocketMQ 版 会进行强制限流。提前配置实例规格水位告...
作为Output接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
将云消息队列 Kafka 版接入阿里云Elasticsearch
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
作为Input接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
作为Output接入
但是会出现部分分区发送消息失败，等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时，默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储（当前仅专业版实例支持选择存储引擎...
死信队列
对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版 不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...
功能与特性概述
是否支持Oneway发送 是否支持多线程发送 性能 普通消息 是 是 是 是 最高 事务消息 定时和延时消息 分区顺序消息 是 否 否 否 高 全局顺序消息 一般 消息特性 消息重试：在消费者返回消息重试的响应后，云消息队列 RocketMQ 版 会按照相应...
使用限制
云消息队列 RocketMQ 版 对某些具体指标进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时注意不要超过相应的限制值，以免程序出现异常。限制项 限制值 说明 Topic名称长度 64个字符 Topic名称长度不得超过该限制，否则会导致无法发送...
订阅关系（Subscription）
行为约束 订阅关系一致 云消息队列 RocketMQ 版 是按照消费者分组粒度管理订阅关系，因此，同一消费者分组内的消费者在消费逻辑上必须保持一致，否则会出现消费冲突，导致部分消息消费异常。正确示例/Consumer c1 Consumer c1=...
基本概念
云消息队列 RocketMQ 版 的Pull Consumer会按顺序依次消费分区内的每条消息，记录已经消费了的消息条数，称为消费位点ConsumerOffset。剩余的未消费的条数（也称为消息堆积量）=最大位点MaxOffset-消费位点ConsumerOffset。Consumer实例 ...
基本概念
消费位点（ConsumerOffset）一条消息被某个消费者消费完成后不会立即从队列中删除，云消息队列 RocketMQ 版 会基于每个消费者分组记录消费过的最新一条消息的位点，即消费位点。更多信息，请参见 消费进度管理。消息索引（MessageKey）消息...
Topic引流
如果原有的Topic流量较大，可能会出现集群节点之间流量不均衡。原有的Topic流量非常小，并且集群扩容后原有的Topic流量没有较大提升。集群扩容后会新建Topic，并且绝大部分流量会打在新建的Topic上。立即生效。操作步骤 说明 云消息队列 ...
Topic导入/导出
导入完成后，选中的待导入的Topic会出现在Topic列表中。相关文档 如果您需要同时跨实例同步Group的列表信息，请参见 Group导入/导出。如果您需要迁移自建RockketMQ集群的数据到阿里云的 云消息队列 RocketMQ 版 上，请参见 自建RocketMQ...
Topic导入/导出
导入完成后，选中的待导入的Topic会出现在Topic列表中。相关文档 如果您需要同时跨实例同步Topic的列表信息，请参见 Group导入/导出。如果您需要迁移自建RockketMQ集群的数据到阿里云的 云消息队列 RocketMQ 版 上，请参见 自建RocketMQ...
查看消费状态
有消息堆积就一定是出现问题了吗？不一定。一般分为以下三种情况：最近消费时间与当前时间接近，并且堆积量保持在一个稳定的数值之间波动，没有持续扩大。说明客户端一直在拉取最新消息，没有消息堆积，属于正常情况。堆积量逐步扩大，并且...
重置消费位点
从指定时间点的位点开始消费：选择此项后会出现时间选择控件。请指定一个时间点，消费者将从这个时间点之后发送的消息开始消费，不管之前的消息是否又被消费过。在弹出的 提示 对话框，确认提示信息，然后单击 确定。消费位点重置常见问题 ...
收发顺序消息
顺序消息FIFO（First In First Out）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的C/C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，...
Filebeat发送失败问题
问题现象 在 云消息队列 Kafka 版 控制台 的 Topic 管理 页面，您已成功创建Topic，但使用Filebeat向该Topic发送消息却出现 Request was for a topic or partition that does not exist on this broker.的错误提示。可能原因 Filebeat向...
Group导入/导出
导入完成后，选中的待导入的Group会出现在Group列表中。相关文档 如果您需要同时跨实例同步Topic的列表信息，请参见 Topic导入/导出。如果您需要迁移自建RockketMQ集群的数据到阿里云的 云消息队列 RocketMQ 版 上，请参见 自建RocketMQ...
消费者（Consumer）
取值：客户端ID由 云消息队列 RocketMQ 版 的SDK自动生成，主要用于日志查看、问题定位等运维场景，不支持修改。通信参数 接入点信息（必选）：连接服务端的接入地址，用于识别服务端集群。接入点必须按格式配置，建议使用域名，避免使用IP...
生产者（Producer）
消息按照到达 云消息队列 RocketMQ 版 服务端的顺序存储到主题的指定队列中。消费者按照指定的订阅关系从 云消息队列 RocketMQ 版 服务端中获取消息并消费。内部属性 客户端ID 定义：生产者客户端的标识，用于区分不同的生产者。集群内全局...
消息队列Kafka版删除Group后仍然收到消息堆积的告警...
问题描述 使用阿里云消息队列Kafka版时，删除Group后，仍然收到消息堆积的告警信息，如何过滤某个Group的消费堆积告警。问题原因 发生消息堆积告警信息的原因如下：2.2.0以前的Kafka服务端版本，开源Kafka未提供删除Group和消费位点的Open...
为什么消费客户端频繁出现Rebalance？
问题现象 使用 云消息队列 Kafka 版 时，消费客户端频繁出现Rebalance。可能原因 可能导致故障的原因包括：v0.10.2之前版本的客户端：Consumer没有独立线程维持心跳，而是把心跳维持与poll接口耦合在一起。其结果就是，如果用户消费出现...
查看Rebalance详情
当消费客户端出现Rebalance时，您可以查看Rebalance的详情，包括Rebalance的时间、耗时、次数、原因以及...后续步骤 当客户端频繁出现Rebalance时，您可以参考以下文档解决此问题：使用云消息队列 Kafka 版时消费客户端频繁出现Rebalance。
- 产品推荐
- 这些文档可能帮助您