队列机制不可用-队列机制不可用文档介绍内容-阿里云

实例管理

删除实例警告实例删除后将无法恢复，并且若该实例绑定了云消息队列 MQTT 版服务，会导致绑定的微消息队列MQTT版服务不可用，请谨慎操作。标准版实例需要清空实例下的所有Topic和Group资源后才可删除。删除标准版实例标准版实例计费方式...

YARN调度器

主要特性 CapacityScheduler具备如下的特性：多级队列（树形结构）：支持多级租户管理，父队列资源配额能够限制其下所有子队列的资源使用，单个子队列的资源配额也不能超过父队列的资源配额，因此对于多租户管理具备较高的可控性，能够满足...

MQTT快速入门

如果提前删除云消息队列 MQTT 版实例绑定的存储实例，则云消息队列 MQTT 版实例会不可用。请按以下步骤创建并绑定存储实例：在左侧导航栏单击概览，选择您刚创建的云消息队列 MQTT 版实例，单击继续配置。在消息持久化配置对话框...

升级多可用区

升级影响该操作服务不会中断，但可能导致短暂不可用。如果客户端无重连机制。可能导致客户端断开连接无法重连。该操作会引发集群部分节点重启。重要升级多可用区功能当前在灰度状态，如需升级请提交工单申请。操作步骤登录云消息...

服务器证书管理

服务器证书用于客户端...如果证书错误会导致服务短暂不可用。登录云消息队列 MQTT 版控制台，进入服务器证书页面。在证书列表中选择指定的服务器证书，并在其操作列单击启动服务。在弹出的提示对话框中仔细阅读提示信息并单击确认。

使用限制

云存储单分区宕机和升级时可能导致不可用 建议创建的分区数大于1，如果强依赖单分区，可以使用Local存储。说明仅专业版实例支持在创建Topic时将存储引擎类型选择为Local存储，标准版暂不支持。说明云消息队列 Kafka 版不再支持按照...

SDK概述

云消息队列 Kafka 版优化了PLAIN机制，支持不重启实例的情况下动态增加SASL用户。重要若您已部署实例且实例的SSL证书算法位数为1024，当您有更高的安全需求时，您可以升级实例的SSL证书算法位数至4096。详细操作，请参见 SSL证书算法升级...

作为Output接入

取值：true：如果主分区不可用，输出可能阻塞。false：即使主分区不可用，输出不被阻塞。false ssl.certificate_authorities CA证书所在位置。home/admin/filebeat/filebeat-7.7.0-linux-x86_64/ca-cert ssl.verification_mode 认证模式。...

事务消息

同时，传统的大事务可以被拆分为小事务，不仅能提升效率，还不会因为某一个关联应用的不可用导致整体回滚，从而最大限度保证核心系统的可用性。在极端情况下，如果关联的某一个应用始终无法处理成功，也只需对当前应用进行补偿或数据订正...

接入点对比

云消息队列 Kafka 版的PLAIN机制，支持不重启实例的情况下动态增加SASL用户。SCRAM机制：一种在服务端和客户端采用哈希算法对用户名与密码进行身份校验的安全认证机制。云消息队列 Kafka 版使用SCRAM-SHA-256加密算法实现身份校验，比...

产品优势

云消息队列 Kafka 版 100%兼容开源，支持0.10.x~2.6.x的开源版本，无需代码改造无缝迁移上云，体验全托管、免运维的分布式消息队列服务。开箱即用云消息队列 Kafka 版 100%兼容开源，使您无缝迁移上云。兼容开源：云消息队列 Kafka 版 100...

消费者负载均衡

重要队列粒度负载均衡策略保证同一个队列仅被一个消费者处理，该策略的实现依赖消费者和服务端的信息协商机制，云消息队列 RocketMQ 版并不能保证协商结果完全强一致。因此，在消费者数量、队列数量发生变化时，可能会出现短暂的队列分配...

Spring集成

spring.rabbitmq.listener.simple.missing-queues-fatal 如果容器声明的队列在代理上不可用，是否失败；或者如果在运行时删除一个或多个队列，是否停止容器。默认值为true。spring.rabbitmq.listener.simple.idle-event-interval 发布空闲...

开源对比

云消息队列 RabbitMQ 版是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品，能够兼容开源RabbitMQ客户端，与开源RabbitMQ相比，能够解决各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等...

发布者最佳实践

默认情况下，云消息队列 Kafka 版为了提升可用性，并不保证单个分区内绝对有序，在升级或者宕机时，会发生少量消息乱序（某个分区挂掉后把消息Failover到其它分区）。如果业务要求分区保证严格有序，请在创建Topic时选择使用Local存储。

HTTP SDK错误码列表

详细信息，请参见对应的API文档：发送消息API 订阅消息API 确认消息API MessageNotExist Message not exist.404 Topic中无可用的消息。The receipt handle you provided has expired.404 消费消息过慢导致消息重新回到队列生成新的 ...

作为Output接入

云消息队列 Kafka 版可以作为Output接入Logstash。本文说明如何在VPC环境下通过Logstash向云消息队列 Kafka 版发送消息。前提条件购买并部署云消息队列 Kafka 版实例。具体操作，请参见 VPC接入。下载并安装Logstash。具体操作，请...

什么是云消息队列 Confluent 版？

HouseKeeping（健康巡检组件）：用于云消息队列 Confluent 版核心链路的运行时巡检，每分钟会对集群做一次全面扫描诊断，并能针对不健康的状态进行告警。同时，每天还会为阿里云运维人员出具整体巡检报告，方便监控云消息队列 Confluent...

如何快速测试云消息队列 Kafka 版服务端是否正常？

在创建并部署云消息队列 Kafka 版实例后，您可以使用云消息队列 Kafka 版控制台直接发送消息，快速测试服务端是否正常。前提条件您已创建并部署云消息队列 Kafka 版实例，且实例处于服务中状态。操作流程快速测试云消息队列 ...

作为Output接入

云消息队列 Kafka 版可以作为Output接入Filebeat。本文说明如何在VPC环境下通过Filebeat向云消息队列 Kafka 版发送消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。更多信息，请参见 VPC...

API概览

本产品（云消息队列 RocketMQ 5.0 版/2022-08-01）的OpenAPI采用 ROA 签名风格，签名细节参见签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能...

作为Output接入

云消息队列 Kafka 版可以作为Output接入Logstash。本文说明如何在公网环境下通过Logstash向云消息队列 Kafka 版发送消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 ...

新功能发布记录

新增 Serverless后付费实例规格弹性策略 2024-04-08 功能名称功能描述功能类型相关文档升级多可用区云消息队列 Kafka 版 V2系列专业版实例支持从单可用区部署升级为多可用区部署架构。新增升级多可用区 2024-03-12 功能名称功能...

新零售电子价签解决方案（MQTT）

新零售电子价签解决方案由阿里云云消息队列 MQTT 版推出，通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项，其他类似行业可参考该方案...

升级实例配置

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

步骤三：创建资源

当使用云消息队列 Kafka 版进行消息收发时，您需要在已成功部署的Kafka实例中创建Topic和Group资源。生产者需要将消息发送至指定Topic，消费者通过订阅Topic获取消息进行消费。消费者消费消息时，需要指定Group订阅对应的Topic。Group和...

作为Input接入

云消息队列 Kafka 版可以作为Input接入Filebeat。本文说明如何在VPC环境下通过Filebeat从云消息队列 Kafka 版消费消息。背景信息在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 VPC...

实例升降配

存储规格不涉及云消息队列 RocketMQ 版的存储空间根据实际使用量按量付费，您可以随时调整消息存储时长来控制占用的存储空间。公网访问类型支持支持升配和降配。升配：开启公网访问。降配：关闭公网访问。公网流量带宽支持支持升配...

使用ACL功能进行访问控制

云消息队列 Kafka 版优化了PLAIN机制，支持不重启实例的情况下动态增加SASL用户。SCRAM：一种用户名密码校验机制，安全性比PLAIN更高。云消息队列 Kafka 版使用SCRAM-SHA-256。密码 SASL用户的密码。确认密码确认SASL用户的密码。创建...

作为Input接入

云消息队列 Kafka 版可以作为Input接入Logstash。本文说明如何在VPC环境下通过Logstash从云消息队列 Kafka 版消费消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 VPC...

将云消息队列 Kafka 版接入阿里云Elasticsearch

随着时间的积累，云消息队列 Kafka 版中的日志数据会越来越多。当您需要查看并分析庞杂的日志数据时，可通过阿里云Logstash将云消息队列 Kafka 版中的日志数据导入阿里云Elasticsearch，然后通过Kibana进行可视化展示与分析。本文介绍将...

作为Input接入

云消息队列 Kafka 版可以作为Input接入Filebeat。本文说明如何在公网环境下通过Filebeat从云消息队列 Kafka 版消费消息。背景信息在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 ...

作为Input接入

云消息队列 Kafka 版可以作为Input接入Logstash。本文说明如何在公网环境下通过Logstash从云消息队列 Kafka 版消费消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体操作，请参见 ...

CreateSaslUser-创建SASL用户

消息队列 Kafka 版优化了 PLAIN 机制，支持不重启实例的情况下动态增加 SASL 用户。scram：一种用户名密码校验机制，安全性比 PLAIN 更高。消息队列 Kafka 版使用 SCRAM-SHA-256。默认值为 plain。plain Mechanism string 否加密方式。...

DescribeSaslUsers-查询SASL用户

消息队列 Kafka 版优化了 PLAIN 机制，支持不重启实例的情况下动态增加 SASL 用户。scram：一种用户名密码校验机制，安全性比 PLAIN 更高。消息队列 Kafka 版使用 SCRAM-SHA-256。默认值为 plain。scram Password string 密码。Username ...

DeleteSaslUser-删除SASL用户

消息队列 Kafka 版优化了 PLAIN 机制，支持不重启实例的情况下动态增加 SASL 用户。scram：一种用户名密码校验机制，安全性比 PLAIN 更高。消息队列 Kafka 版使用 SCRAM-SHA-256。默认值为 plain。scram Mechanism string 否加密方式。...

排他队列

如果您想创建一个只有自己可见的队列，不允许其他用户访问，您可以使用云消息队列 RabbitMQ 版的排他性队列特性，将指定的队列声明为排他性。什么是排他队列排他性队列的特点如下：排他队列只对首次声明它的连接（Connection）可见，...

常见问题

客户端报错使用云消息队列 Kafka 版时客户端的报错及解决方案使用云消息队列 Kafka 版时出现“Not authorized to access group”的错误信息网络问题无法ping通云消息队列 Kafka 版的接入点不在同一可用区内的ECS实例如何访问云消息...

消息超时和重试机制

重试机制云消息队列 RabbitMQ 版服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试机制和关闭消息重试机制。云消息队列 RabbitMQ 版服务端默认的消息重试机制如下：如果您没有开启Consumer客户端消费消息，则不会...

消费失败是否支持重试？

重试机制云消息队列 RabbitMQ 版服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试机制和关闭消息重试机制。云消息队列 RabbitMQ 版服务端默认的消息重试机制如下：如果您没有开启Consumer客户端消费消息，则不会...

队列机制不可用

新品推荐