循环队列未响应-循环队列未响应文档介绍内容-阿里云

查看Rebalance详情

消费时间过慢，超过一定时间（max.poll.interval.ms 设置的值，默认5分钟）未进行Pull拉取消息，则会导致客户端主动离开队列，触发Rebalance。消费者数量过多，为避免当前Topic-Partition的任务浪费，需要关闭一定数量的消费者，触发...

续费说明

包年包月云消息队列 RocketMQ 版实例到期后会影响服务及资源的正常使用，如果您需要继续使用云消息队列 RocketMQ 版，需要在指定时间内为实例及时续费，否则云消息队列 RocketMQ 版实例及相关资源会被自动释放且不可恢复。本文介绍...

使用云消息队列 Kafka 版时客户端的报错及解决方案

在使用云消息队列 Kafka 版时，客户端可能报错，您可以根据报错消息匹配对应的解决方案。详细信息报错信息对应的详细信息如下。报错信息客户端语言类型报错原因解决方案 TimeoutException Java 网络问题客户端鉴权（sasl.mechanisms）...

生产者（Producer）

本文介绍云消息队列 RocketMQ 版中生产者（Producer）的定义、模型关系、内部属性、版本兼容性及使用建议。定义生产者是云消息队列 RocketMQ 版系统中用来构建并传输消息到服务端的运行实体。生产者通常被集成在业务系统中，将业务...

云监控

实例公网写入带宽 bit/s 实例公网读取带宽 bit/s Topic Topic消息生产流量 Bytes/s Topic消息消费流量 Bytes/s Group Group未消费消息总数个计费说明使用云监控功能云消息队列 Kafka 版不收取费用。前提条件创建服务关联角色角色...

按量计费转包年包月

前提条件您已购买并部署云消息队列 Kafka 版实例，且实例运行状态处于服务中或未部署。具体操作，请参见步骤二：购买和部署实例。注意事项按量计费转包年包月的过程中，实例始终处于服务中状态，不会因为实例重启而导致服务短暂不...

全球消息路由定价详情

全球消息路由为云消息队列 RocketMQ 版的高级功能，若您开通了全球消息路由功能，云消息队列 RocketMQ 版会按照按量付费的方式进行计费，未使用该服务则不计费。高级功能不能单独使用，必须配合基础功能即消息收发功能一起使用。本文...

查看消费者状态

如果消息消费出现异常，您可以在云消息队列 RocketMQ 版控制台查看指定Group ID的消费状态，包括消费者在线状态、订阅关系一致性结果、消费堆积相关指标、消费者客户端信息等，帮助您快速定位异常原因。应用场景消费者状态信息包括在线...

JMS概述

云消息队列 RabbitMQ 版提供JMS库供JMS客户端接入云消息队列 RabbitMQ 版。本文介绍云消息队列 RabbitMQ 版 JMS库的相关概念、获取方式、使用限制和使用教程。背景信息 JMS是一种消息传递标准，允许基于Java EE（Java平台企业版）的应用...

正式商用公告

本章节介绍云消息队列 Kafka 版的正式商用公告细则。正式商用细则云消息队列 Kafka 版的正式商用细则如下：为提高服务质量和用户体验，云消息队列 Kafka 版全部以商用实例方式提供服务。实例的基本规格和定价信息请参见计费概述。...

实例管理

本文介绍如何对云消息队列 MQTT 版的实例进行续费、变配及运维管理。实例续费云消息队列 MQTT 版实例到期之前7天会按照账号给对应的手机发送通知，请及时续费。如果到期未续费，实例将被保留7天，之后自动释放。登录云消息队列 MQTT ...

实例续费和升降配

本文介绍如何对云消息队列 MQTT 版实例进行续费、升配及降配操作。背景信息升配和降配操作对当前订单周期生效，续费在当前订单周期结束后下一订单周期生效。实例续费系统会在实例到期前7天，按照账号给对应的手机发送通知，请及时续费...

客户端首次接入云消息队列 Kafka 版时出现异常的排查...

概述本文主要介绍客户端首次接入云消息队列 Kafka 版时，出现异常的排查方法。详细信息客户端首次接入云消息队列 Kafka 版时如果出现异常，您可以通过以下三个方面进行排查：网络连通问题：通常有如下几种情况可能会导致网络不通，客户端...

集成概述

版本说明云消息队列 Kafka 版的Connector共有两个版本，若您的阿里云账号未创建过旧版Connector，那么控制台仅展示新版入口；若已创建过旧版Connector任务，控制台会同时展示新版和旧版入口，建议您使用新版Connector。新旧版本消息流入...

消息存储和清理机制

消息在队列中的存储情况如下：消息存储管理粒度说明云消息队列 RocketMQ 版按照服务端节点粒度管理存储时长而非队列或主题，原因如下：消息存储优势权衡：云消息队列 RocketMQ 版基于统一的物理日志队列和轻量化逻辑队列的二级组织方式...

企业铂金版计费说明

如果服务端未返回消息，则计算为1次投递次数。说明云消息队列 RocketMQ 版有4种消息类型：普通消息、定时和延时消息、事务消息以及顺序消息，其中，定时和延时消息、事务消息以及顺序消息为高级特性消息。更多信息，请参见消息类型列表...

包年包月

支付成功后，资源被系统分配，直到资源有效期到期后未续费而被回收。计费公式在包年包月模式下，您按需选择云消息队列 Confluent 版版本、磁盘容量等配置项完成实例购买，计费从您成功下单开始。云消息队列 Confluent 版版本不同所产生...

收发普通消息（三种方式）

阿里云云消息队列 RocketMQ 版提供三种方式来发送普通消息：同步发送、异步发送和单向（Oneway）发送。本文介绍了每种发送方式的原理、使用场景、示例代码，以及三种发送方式的对比；此外还提供了订阅普通消息的示例代码。前提条件您已...

API概览

本产品（微消息队列 MQTT/2020-04-20）的OpenAPI采用 RPC 签名风格，签名细节参见签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用需求...

实例升降配

升降配操作入口系统会根据您的实例的计费方式和配置自动计算出当前实例支持的变更操作，若您在以下操作入口未找到相关操作项，说明当前实例不支持该操作。登录云消息队列 RocketMQ 版控制台。在实例列表页面找到待变更配置的实例，并...

退订实例

预付费实例退订规则退款规则云消息队列 RabbitMQ 版的退订规则为非全额退款，系统按照实际使用时长计算费用，并退回未使用时长对应的金额。退订金额＝订单实付金额－已使用价值具体退订规则和示例，请参见退订规则说明。退订流程在 ...

消息收发定价详情

消息收发功能为云消息队列 RocketMQ 版的基础功能，您只要开通云消息队列 RocketMQ 版服务，则默认使用消息收发功能。本文介绍云消息队列 RocketMQ 版标准版实例的消息收发功能费用详情和计费示例。计费公式标准版实例根据消息收发...

Topic管理

计费说明云消息队列 RocketMQ 版会对已创建的每一个Topic收取Topic资源占用费，即使Topic未使用也会产生费用，建议您及时删除不需要使用的Topic。更多计费信息，请参见消息收发定价详情和企业铂金版计费说明。Topic命名规范 Topic名称...

什么是云消息队列 RocketMQ 版？

云消息队列 RocketMQ 版是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台，面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。为什么选择云...

退款说明

退款规则云消息队列 RocketMQ 版的退订规则为非全额退款，系统将按照实际使用时长计算费用，并退回未使用时长对应的金额。退订金额=订单实付金额-已消费金额具体的规则说明和示例，请参见退订规则说明。退订流程云消息队列 RocketMQ ...

迁移上云操作

和开源Apache RocketMQ相比，阿里云云消息队列 RocketMQ 版具有更高的稳定性、安全性及更完善的运维体系。您可以将开源RocketMQ集群迁移到云消息队列 RocketMQ 版上以获得更好的业务体验。本文为您介绍如何使用云消息队列 RocketMQ 版...

使用限制

单实例消息收发TPS 根据购买的规格进行限流，云消息队列 MQTT 版消息收发TPS超过规格上限后，客户端（包含开源MQTT客户端和云端SDK）可能会出现连接断开、响应超时和消息丢弃等情况，不保证消息可靠到达。在MQTT客户端场景下，单MQTT客户...

订阅者最佳实践

本文主要介绍云消息队列 Kafka 版订阅者的最佳实践，帮助您减少消费消息出错的可能性。消费消息基本流程云消息队列 Kafka 版订阅者在订阅消息时的基本流程为：Poll数据→执行消费逻辑→再次Poll数据，详情参见下图。负载均衡每个 ...

常见问题

本文汇总了使用云消息队列 Kafka 版实例时的常见问题。计费问题为什么购买了按量付费实例后不使用也要收费？为什么按流量峰值收费？按流量峰值收费的依据是什么？为什么额外增加分区要收费？我使用的Connector组件如何计费？客户端报错 ...

新功能发布记录

本文介绍云消息队列 Kafka 版的产品功能动态及对应的文档。2024-04-15 功能名称功能描述功能类型相关文档 V3.0 Serverless系列实例在华东2（上海）地域开服云消息队列 Kafka 版 V3.0 Serverless系列实例支持在华东2（上海）地域选购...

监控报警

云监控服务具有指标采集、可视化、实时报警等功能，云消息队列 MQTT 版支持通过云监控创建告警规则，帮助您自动监控服务的运行状态，并自动发送报警通知，便于您及时预警服务的异常信息，提高运维效率。监控项说明说明云监控中统计的...

公网访问费用

云消息队列 RocketMQ 版支持公网访问和VPC访问。实例开启公网访问后，系统会按照公网下行带宽大小和使用时长收取公网访问费用。若未开启公网访问，则不收取公网访问费用。公网访问有一定的公网流量成本，建议您尽量选择VPC网络访问。计费...

升级实例配置

本文介绍如何在云消息队列 Kafka 版控制台完成实例升配，升级的配置项包括规格类型、流量规格、磁盘容量及分区规格等。前提条件实例处于服务中或未部署状态。实例中没有进行中的Topic引流任务。注意事项升级实例配置会引发集群逐台...

仪表盘

借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 RocketMQ 版提供仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标，进而快速了解业务的运行状态。本文介绍仪表盘的应用场景、业务背景...

迁移自建Kafka集群至新实例

本文介绍如何在云消息队列 Kafka 版控制台创建并启动迁移任务。前提条件下载JDK 8 安装Tsar 为了更准确的获取执行机器的配置，推荐您提前安装Tsar软件。您也可以在运行迁移工具时通过指定-installTsar 参数自动安装Tsar软件，但自动安装...

公共参数

Date 是请求的构造时间，目前只支持GMT格式，如果和云消息队列 RocketMQ 版的服务器时间前后差异超过15分钟将返回本次请求非法。Host 是即在控制台实例详情页面查看到的HTTP接入点。x-mq-version 是调用云消息队列 RocketMQ 版的...

重置消费位点

云消息队列 RocketMQ 版支持以下方式重置消费位点：从最新位点开始消费消费者消费指定Topic中的消息时，会跳过当前堆积（未被消费）的所有消息，从重置操作时间后发送的最新消息开始消费。从指定时间点的位点开始消费消费者将从重置时间...

领域模型概述

本文为您介绍云消息队列 RocketMQ 版的领域模型。产品定位云消息队列 RocketMQ 版是一款典型的分布式架构下的中间件产品，使用异步通信方式和发布订阅的消息传输模型。通信方式和传输模型的具体说明，请参见下文通信方式介绍和消息...

计费概述

云消息队列 RabbitMQ 版提供包年包月预付费和Serverless按量后付费计费方式，每种计费方式的计费项和计费规则都有所差异，您可以按照不同的使用场景和业务规模选择合适计费方式及实例类型，达到成本最优化的效果。实例类型和计费模式说明...

队列（MessageQueue）

队列的主要作用如下：存储顺序性队列天然具备顺序性，即消息按照进入队列的顺序写入存储，同一队列间的消息天然存在顺序关系，队列头部为最早写入的消息，队列尾部为最新写入的消息。消息在队列中的位置和消息之间的顺序通过位点（Offset...

循环队列未响应

新品推荐