什么是消息队列Kafka版?

三分钟了解阿里云消息队列Kafka版。
来自: 阿里云 >帮助文档

不同地域中的同名队列是同一个队列吗?

本文介绍不同地域的同名队列之间的关系。不同地域中的同名队列不是同一个队列,不同地域的同名队列是各自独立的。
来自: 阿里云 >帮助文档

删除队列消息

本文介绍如何删除某个队列的所有消息。您可以使用Java客户端库中queuePurge方法删除某个队列的所有消息。示例代码如下: channel.queuePurge("queue-name");
来自: 阿里云 >帮助文档

阿里云试用中心,为您提供0门槛上云实践机会!

0元试用32+款产品,最高免费12个月!拨打95187-1,咨询专业上云建议!
广告

是否支持优先级队列

消息队列RabbitMQ版不支持优先级队列。消息队列RabbitMQ版内部暂未实现消息优先级的处理逻辑,您的客户端通过可选队列参数x-max-priority 声明的优先级队列实际是无效的。
来自: 阿里云 >帮助文档

什么不能登录部署消息队列Kafka版的机器?

消息队列Kafka版提供全托管免运维服务,您无需登录机器。消息队列Kafka版是全托管的,由消息队列Kafka版 专业团队进行运维保障,您无需登录机器。集群的一些基础信息会通过监控告警进行透传。
来自: 阿里云 >帮助文档

是否支持优先级队列

消息队列RabbitMQ版不支持优先级队列。消息队列RabbitMQ版内部暂未实现消息优先级的处理逻辑,您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。
来自: 阿里云 >帮助文档

否定应答并重入队列

当某个Consumer不能立即消费消息且其他Consumer可以消费时,您可以使该Consumer否定应答消息并使其重入队列,从而使其他Consumer可以消费消息。本文说明Consumer如何否定应答消息并使其重入队列。Consumer否定应答单...
来自: 阿里云 >帮助文档

否定应答并重入队列

当您希望某个Consumer不能立即消费消息且其他Consumer可以消费消息时,您可以使该Consumer否定应答消息并使其重入队列,从而使其他Consumer可以消费消息。本文说明如何否定应答消息并使其重入队列。Consumer否定应答...
来自: 阿里云 >帮助文档

MNS相对于自主研发、商用或开源的消息队列系统有什么...

本文介绍与自行构建系统来管理消息队列或使用商用、开源的消息和通知服务相比,使用消息服务MNS的优势。消息服务MNS的优势如下所示: 无需大量前期投入来进行开发、配置。随着您业务量的不断增大,无需持续投入硬件...
来自: 阿里云 >帮助文档

对于较长时间没有任何消息的队列,会如何处理?

本文介绍对于较长时间没有任何消息的队列,阿里云会如何处理的问题。在您正常使用消息服务MNS服务期间,阿里云不会对非活跃的队列或主题进行删除操作。但是,如果您的 消息服务MNS使用权限因为欠费或其他原因被停止...
来自: 阿里云 >帮助文档

能否通过公网访问消息队列Kafka版实例?

网络类型为公网/VPC的消息队列Kafka版实例支持通过公网访问。消息队列Kafka版 提供VPC和公网/VPC两种网络类型的实例。如需通过公网访问,请在购买时选择网络类型为公网/VPC的消息队列Kafka版实例。注意 实例的网络...
来自: 阿里云 >帮助文档

如何快速使用消息队列Kafka版的Java SDK收发消息

六分钟上手消息队列Kafka版。文档教程 快速入门
来自: 阿里云 >帮助文档

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

在创建并部署消息队列Kafka版实例后,您可以使用消息队列Kafka版控制台直接发送消息,快速测试服务端是否正常。前提条件 您已创建并部署消息队列Kafka版 实例,且实例处于服务中状态。...在左侧导航栏,单击Topic管理。...
来自: 阿里云 >帮助文档

如何快速使用消息队列RabbitMQ版Spring Boot Demo收发...

本文提供使用消息队列RabbitMQ版Spring Boot Demo收发消息的快速入门视频。
来自: 阿里云 >帮助文档

使用消息队列Kafka版时消费客户端频繁出现Rebalance

问题描述 使用消息队列Kafka版时,消费客户端(Consumer)频繁出现Rebalance。问题原因 可能导致故障的部分原因如下: 开源版本为v0.10的消息队列Kafka版有一定的概率会触发频繁Rebalance。消息队列Kafka版 的...
来自: 阿里云 >帮助文档

消息队列Kafka版何时删除旧消息?

为避免因磁盘容量不足而导致机器宕机,进而影响服务可用性,消息队列Kafka版对磁盘使用率进行了动态控制。磁盘使用率低于85%:每天凌晨4点集中删除超过存储时间的消息。磁盘使用率达到85%:立即清除超过存储时间的...
来自: 阿里云 >帮助文档

消息队列RabbitMQ版实例消费失败时的重试逻辑

概述 本文主要介绍消息队列RabbitMQ版实例消费失败时的重试逻辑。详细信息 消息队列RabbitMQ版 服务端有默认的消息重试机制,不支持您在Consumer客户端重新配置消息重试机制。消息队列RabbitMQ版服务端默认的消息重...
来自: 阿里云 >帮助文档

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

概述 在使用消息队列Kafka版时,客户端可能报错,您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端...
来自: 阿里云 >帮助文档

如何保证我的消息队列中的消息是安全的?

本文介绍阿里云如何保证消息队列中的消息是安全的。消息服务MNS 提供了安全可靠的身份验证机制,确保您的队列受到保护,防止遭到未经授权的访问。只有阿里云账户拥有者才能访问其创建的队列
来自: 阿里云 >帮助文档

使用消息队列Kafka版时出现消息堆积

问题描述 使用消息队列Kafka版时出现消息堆积。问题原因 消息队列Kafka版 的消息是客户端主动去服务端拉取的,因为是批量拉取机制,服务端一般不会是消费的瓶颈。消息堆积大多是消费速度过慢或者消费线程阻塞造成的...
来自: 阿里云 >帮助文档

删除队列后,是否仍然会继续计费?

本文介绍删除队列后计费系统...如果您不再需要使用某个队列,在删除该队列后,从删除的第二天起将不再收取该队列的资源占用费,同时需要停止针对该队列的所有API请求,否则消息服务MNS 仍然会按照API请求次数进行计费。
来自: 阿里云 >帮助文档

如何通过代理访问消息队列Kafka版实例

概述 暂不支持通过代理访问消息队列Kafka实例,具体请查看详细信息。详细信息 消息队列Kafka版的客户端访问服务端的原理如下。通过bootstrap.servers随机访问服务器获取Metadata。通过Metadata里的IP地址进行后续的...
来自: 阿里云 >帮助文档

连接微消息队列MQTT版的服务端时异常断开

问题描述 连接微消息队列MQTT版的服务端时异常断开。问题原因 有如下两种可能的问题原因。客户端发送Publish和Subscribe报文时,微消息队列MQTT版的服务端将进行权限验证。如果权限验证失败则会断开连接。不同的客户...
来自: 阿里云 >帮助文档

无法ping通消息队列Kafka版的接入点

问题描述 无法ping通消息队列Kafka版的接入点。问题原因 为了保证安全,消息队列Kafka版集群默认禁ping。解决方案 您可以通过 telnet命令测试网络连通性。但需要注意以下几点要求。执行telnet命令的客户端在白名单...
来自: 阿里云 >帮助文档

消息队列MQTT版的客户端存在流量限制

问题描述 使用消息队列MQTT版发送消息到订阅客户端,未正常收到消息。问题原因 单个Client ID如果短时间内有大量的消息发送,会出现被限流的情况。解决方案 建议客户端降低收发的频率。如果有高并发发送的需求,可以...
来自: 阿里云 >帮助文档

购买微消息队列MQTT版预付费实例后产生额外费用的原因

概述 已经付费购买微消息队列MQTT版的预付费实例,收发消息后产生了额外的费用。本文主要介绍此问题的原因。详细信息 微消息队列MQTT版 实例是一个无状态网关类型实例,用来完成IoT移动场景客户端连接维持和消息转发...
来自: 阿里云 >帮助文档

消息队列Kafka版实例删除Consumer Group后仍然可以...

问题描述 使用消息队列Kafka版实例时,删除Consumer Group后仍然可以接收到消息。问题原因 历史版本的消息队列Kafka版实例在删除Consumer Group时,不会彻底清除路由信息,...在左侧导航栏,单击Consumer Group管理。...
来自: 阿里云 >帮助文档

使用微消息队列MQTT版时无法收到部分Topic的消息

问题描述 使用微消息队列MQTT版时,有的Topic消息可以收到,有的却不能。问题原因 单个微消息队列MQTT版的 客户端允许持有的订阅关系有数量限制,最多30个。如果订阅数量超过限制,则会被丢弃,导致收不到这部分消息...
来自: 阿里云 >帮助文档

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

概述 本文主要介绍客户端首次接入消息队列Kafka版时,出现异常的排查方法。详细信息 客户端首次接入消息队列Kafka版时如果出现异常,您可以通过下列三个方面进行排查: 网络连通问题:通常有如下几种可能性导致网络...
来自: 阿里云 >帮助文档

不在同一可用区内的ECS实例如何访问消息队列Kafka版...

概述 不在同一可用区内的ECS实例可通过非公网的方式访问消息队列Kafka版实例,详情请查看以下内容。详细信息 以非公网的方式访问消息队列Kafka版 实例时,必须满足以下两个条件: ECS实例与消息队列Kafka版实例在同...
来自: 阿里云 >帮助文档

消息队列Kafka版控制台的报警项中状态列显示“数据...

问题描述 在消息队列Kafka版控制台的报警项中,状态列显示“数据不足”。问题原因 虽然配置了报警规则,但您的消息队列Kafka版 实例版本低,不支持报警数据上报。解决方案 请升级消息队列Kafka版实例的版本至最新...
来自: 阿里云 >帮助文档

使用微消息队列MQTT版时收到短信告警提示“使用非法的...

ID,登录微消息队列MQTT版控制台,进入Group管理,检查该Group ID是否已经创建。如果没有创建,您需要手动申请创建。关于如何创建Group ID,您可以参考MQTT快速入门。注:Group ID的命名必须符合规范才可以申请成功...
来自: 阿里云 >帮助文档

消息队列Kafka版各分区(Partition)的消费时间不一致

问题描述 消息队列Kafka版各分区(Partition)的消费时间不一致,...Group管理页面,查看的消费时间不是该消息的消费时间,而是本分区中最近消费的消息存储时间。...为什么各分区收到生产者消息的时间不一致,原因如下。...
来自: 阿里云 >帮助文档

使用消息队列RocketMQ版时message类的userproperties...

概述 使用消息队列RocketMQ版时,message类的userproperties属性如何自定义。详细信息 userproperties属性是Properties类型,您可以根据自己的需求添加Key-Value类型的属性到message中,示例如下:Message message=...
来自: 阿里云 >帮助文档

使用消息队列Kafka版时出现“Not authorized to ...

问题描述 使用消息队列Kafka版时出现“Not authorized to access group”的错误信息。问题原因 没有创建Consumer Group时会遇到此报错信息。解决方案 您可以选择如下任意一种方式创建Consumer Group。在消息队列...
来自: 阿里云 >帮助文档

MNS如何保证多个消费者访问同一消息队列,不会丢失...

本文介绍消息服务MNS如何保证多个消费者访问同一消息队列,不会丢失消息或者重复消费消息的问题。消息服务MNS 中每个队列都具有可配置的不可见时间段属性(即队列的取出消息隐藏时长属性)。当队列中的某条消息被...
来自: 阿里云 >帮助文档

媒体工作流执行时,转码管道上绑定的队列或通知机制...

目前媒体工作流触发执行的作业,忽略转码管道上绑定的消息机制;
来自: 阿里云 >帮助文档

消息队列Kafka版实例中重新创建已经删除过的Topic时...

问题描述 消息队列Kafka版实例中,重新创建已经删除过的Topic并且分区数小于上次创建时设置的分区数,系统提示以下信息。创建topic成功,分区数不能小于曾经配置过的分区数,已重置为...在左侧导航栏,单击Topic管理。...
来自: 阿里云 >帮助文档

消息队列Kafka版的消费端从服务端拉取不到消息或者...

登录消息队列Kafka版的控制台,单击 监控报警,查看监控信息。关于如何查看或者设置实例的监控报警信息,请参阅监控报警。检查 实例消息消费流量 是否已经达到实例的带宽峰值。如果已经达到带宽峰值,您需要升级实例...
来自: 阿里云 >帮助文档

如何在控制台管理Consumer的offset?

本文说明在解决Consumer在读取消息异常中断后,如何在控制台管理Consumer的offset。消费消息并不保证会提交消费位点,Broker记录的是客户端提交的消费位点,提交就是消费确认的意思。提交的机制取决于您使用的客户端...
来自: 阿里云 >帮助文档

计费FAQ

保持连接,即代码逻辑层面还在主动发起连接到消息队列RabbitMQ版 的请求。连接的参数指向之前...我没有使用消息队列AMQP版服务,为什么会扣费?请登录费用管理中心查看账单,检查您是否有使用消息队列RabbitMQ版服务。...
来自: 阿里云 >帮助文档

什么需要升级实例来支持监控告警功能?

2018年11月以前部署的消息队列Kafka版集群不支持上报监控告警数据,需要升级来支持监控告警功能。在控制台上可以查看和设置监控告警功能,但是在2018年11月以前部署的消息队列Kafka版集群不支持上报监控告警数据,...
来自: 阿里云 >帮助文档

什么额外增加Topic要收费?

消息队列Kafka版优化了额外增加Topic所带来的性能下降问题。自建开源Apache Kafka集群分区数大于1000之后,集群性能开始急剧下降。按照最常见的1个Topic对应24个分区的情况,单个集群对应不到50个Topic就开始遭遇...
来自: 阿里云 >帮助文档

控制台看到的最近消费时间是什么意思?

消息发布到消息队列Kafka版服务器的存储时间。控制台看到的最近消费时间是指消息发布到消息队列Kafka版 服务器的存储时间。如果消费没有堆积,那么这个时间接近发送时间。
来自: 阿里云 >帮助文档

什么限制Topic总数(分区总数)?

Topic总数(分区总数)太多会使集群性能和稳定性能急剧下降。消息队列Kafka版 的存储和协调机制是以分区为粒度的,分区数太多,会导致存储碎片化严重,集群性能和稳定性都会急剧下降。
来自: 阿里云 >帮助文档

什么购买了按量付费实例后不使用也要收费?

按量付费模式与购买后是否实际使用无关。您在购买消息队列Kafka版按量付费实例后,系统会为您分配相应的实例资源。因此,按量付费模式是以实例单价× 服务时间计费的,与您购买后是否使用该实例无关。
来自: 阿里云 >帮助文档

ExchangeHasDiffFields

CreateExchange或在消息队列RabbitMQ版控制台的Exchange管理页面创建的Exchange默认为持久化Exchange。autoDelete boolean Exchange是否自动删除。取值: true:自动删除类型,在最后一个Consumer取消订阅后,自动...
来自: 阿里云 >帮助文档

QueueHasDiffField

CreateQueue或在消息队列RabbitMQ版控制台的Queue管理页面创建的Queue默认为持久化Queue。exclusive boolean Queue是否具有排他性: true:排他性类型,只对首次声明其的Connection可见,且会在Connection断开时自动...
来自: 阿里云 >帮助文档

如何获取部署实例时需要的VPC信息?

您可以在VPC管理控制台获取VPC信息。获取VPC信息的步骤如下: 登录VPC管理控制台。在左侧导航栏,单击交换机。在交换...可用区 说明 请根据该页面的可用区(A~G)在消息队列Kafka版控制台中选择对应的可用区(A~G)。...
来自: 阿里云 >帮助文档

如何进行发送消息的测试?

您可以直接在消息队列Kafka版控制台进行发送消息的测试。您可以在控制台的 Topic管理页面,单击目标Topic右侧的发送消息 进行消息发送测试,以验证集群是否运转正常。
来自: 阿里云 >帮助文档

消息负载均衡策略

消息队列 RocketMQ 版的消息负载策略针对发布方和订阅方有所差异。对订阅方而言,消息负载策略在一定程度上影响消息堆积。发布方消息负载均衡策略 消息队列 RocketMQ 版针对发布方采取的是轮询制,即 Producer 的...
来自: 阿里云 >帮助文档

如何处理不活跃的Topic?

通过管理控制台查看Topic信息 通过OpenAPI批量查询Topic信息 登录消息队列Kafka版控制台。在顶部菜单栏,选择地域。在左侧导航栏,单击Topic管理。在Topic管理页面,选择目标实例,然后找到目标Topic,在其操作列中...
来自: 阿里云 >帮助文档

什么分区消费时间相差较大、滞后明显或乱序?

现象 在消息队列Kafka版控制台的Consumer Group页签,单击查看消息堆积,显示某分区的最近消费时间 比其他分区早,说明分区先收到来自Producer的消息。原因 同一个Consumer Group的所有消费端实例,会按分区均匀分配...
来自: 阿里云 >帮助文档

什么按流量峰值收费?

从业务维度收费比从硬件维度收费更能反应业务的使用量。常见的计费方式有两种:一种是从硬件维度,一种是从业务维度。从硬件维度计费,难以对标业务的实际使用量;从业务维度收费,则直接对应业务的使用量。
来自: 阿里云 >帮助文档

是否支持Topic自动创建?

消息队列Kafka版部分支持Topic自动创建。消息队列Kafka版Topic自动创建请参见自动创建Topic。Topic自动创建,使用起来方便,运维起来却极其麻烦,且极易造成系统不稳定。消息队列Kafka版 的Topic还涉及一系列鉴权...
来自: 阿里云 >帮助文档

按流量峰值收费的依据是什么

流量峰值能说明整个集群的处理能力。流量峰值不仅指带宽,还说明整个集群的处理能力。例如,实例的流量峰值为30MB/s,则说明该实例每天具备30MB/s×60s×60×24÷ 1024÷1024=2.4T的数据通道处理能力。
来自: 阿里云 >帮助文档

是否支持延迟消息?

和开源Apache Kafka一样,消息队列Kafka版同样不支持延迟消息。
来自: 阿里云 >帮助文档

什么Topic不能减分区?

Topic减分区会造成数据丢失。这是Apache Kafka自身设计所限制的。
来自: 阿里云 >帮助文档

设置Message ID

如需追踪和识别消息,您可以在消息队列RabbitMQ版的Producer客户端设置Message ID属性,为每条消息设置唯一标识符。本文介绍...什么是Message ID Message ID(消息标识符)是消息的可选属性,类型为short string。...
来自: 阿里云 >帮助文档

RAM用户登录管理控制台后看不到监控信息

问题描述 RAM用户登录管理控制台后看不到监控信息,但是主账号可以看到。问题原因 RAM用户未被授予云监控相关...消息队列 Kafka 版 如果您的问题仍未解决,您可以在阿里云社区免费咨询,或提交工单联系阿里云技术支持。
来自: 阿里云 >帮助文档

什么Topic有分区时间显示1970?

该Topic分区没有被发送过消息。如果没有发送过消息到某Topic分区,那么对应Topic分区的最近更新时间就是显示为1970。
来自: 阿里云 >帮助文档

实例支持哪些开源版本?

本文介绍消息队列Kafka版实例支持哪些开源版本。消息队列Kafka版标准版实例:仅支持0.10.x,默认部署0.10.x,如需更高版本请先将实例升级为专业版,然后升级实例版本,详情请参见升级实例配置和 升级实例版本。消息...
来自: 阿里云 >帮助文档

消息堆积了怎么办?

消息队列Kafka版 的消息是客户端主动去服务端拉取的,一般来说,因为是批量拉取机制,服务端拉取都不会是消费的瓶颈。消息堆积一般是消费速度过慢或者消费线程阻塞造成的。建议打印消费消息的耗时,或者查看堆栈信息...
来自: 阿里云 >帮助文档

是否支持Consumer Group自动创建?

消息队列Kafka版部分支持Consumer Group自动创建。消息队列Kafka版Consumer Group自动创建请参见自动创建Consumer Group。Consumer Group自动创建,使用起来方便,运维起来却极其麻烦,且极易造成系统不稳定。消息...
来自: 阿里云 >帮助文档

是否支持压缩消息?

消息队列Kafka版服务端支持收发压缩消息。如需使用压缩消息,您需要在消息队列Kafka版的客户端进行设置。在消息队列Kafka版 客户端进行消息压缩的说明如下: 压缩格式:支持Snappy、LZ4、GZIP等压缩格式。其中,GZIP...
来自: 阿里云 >帮助文档

Topic的存储有哪些类型?

云存储和Local存储。消息队列Kafka版实例支持云存储和Local存储。详情请参见存储引擎对比。
来自: 阿里云 >帮助文档

设置Message ID

如需追踪和识别消息,您可以在消息队列RabbitMQ版的Producer客户端设置Message ID属性,为每条消息设置唯一标识符。本文介绍...什么是Message ID Message ID(消息标识符)是消息的可选属性,类型为short string。...
来自: 阿里云 >帮助文档

是否支持Compact的日志清理策略?

开源版本为2.2.0或以上的消息队列Kafka版实例支持Compact的日志清理策略。开源版本为2.2.0或以上的消息队列Kafka版 实例支持Compact的日志清理策略。如需升级实例的开源版本以支持Compact的日志清理策略,请参见升级...
来自: 阿里云 >帮助文档

商业化服务条款

本服务条款是阿里云计算有限公司(以下简称“阿里云”)与您就消息队列服务(Message Queue,简称 ...应用数据接口、技术说明、设计、特殊公式、特殊算法等)。...而非以您获得管理员身份(包括获取了管理员登录号和密码)...
来自: 阿里云 >帮助文档

VPC实例和公网/VPC实例的区别是什么

VPC实例仅支持VPC访问,公网/VPC实例既支持VPC访问,也支持公网访问。VPC实例:仅提供专有网络VPC接入点,只能通过专有网络VPC访问。公网/VPC实例:提供公网接入点和专有网络VPC接入点,可以通过公网访问,也可以...
来自: 阿里云 >帮助文档

什么有Consumer Group对应的Topic分区显示1970?

Consumer Group没有消费过该Topic分区的消息。如果Consumer Group没有消费过某Topic分区的消息,那么Consumer Group对应的Topic分区的最近消费时间就是显示为1970。
来自: 阿里云 >帮助文档

什么是死分区和假堆积?

死分区指长期没有数据发送进来的分区,死分区存在没有被完全删除的消息就会出现假堆积。当一个分区,长期没有数据发送进来时,就慢慢变成了死分区。死分区,通常不会造成使用问题,但却给监控报警等问题带来干扰。...
来自: 阿里云 >帮助文档

Topic删除后不能减少分区?

确保实例的内部版本为最新版 在消息队列Kafka版控制台,进入实例详情页面,在基本信息区域的内部版本的右侧,查看服务版本: ...创建—删除—再创建 进入Topic管理页面,创建之前删除的Topic,删除该Topic,然后再次...
来自: 阿里云 >帮助文档

什么告警堆积量和控制台堆积量不一致?

一般是因为死分区。一般是因为死分区。当一个分区在服务端没有位点时,控制台默认取最大位点-最小位点作为堆积值,堆积告警默认取最大位点作为堆积值。小版本为最新版的实例优化了堆积告警,改为默认取最大位点-最小...
来自: 阿里云 >帮助文档

Consumer Group删除后依然可以收到消息?

将服务版本升级为最新版 将服务版本升级为最新版 在消息队列Kafka版控制台,进入实例详情页面,在基本信息区域的内部版本的右侧,查看服务版本: ...创建—删除—再创建 进入Consumer Group管理页面,创建之前删除的...
来自: 阿里云 >帮助文档

报警项状态显示数据不足怎么办?

消息队列Kafka版实例不支持报警数据上报。解决方案 登录消息队列Kafka版控制台。在顶部菜单栏,选择目标实例所在地域。在左侧导航栏,单击实例详情。在实例详情页面上方,单击目标实例。在基本信息区域的内部版本...
来自: 阿里云 >帮助文档

客户端首次接入如何排查问题?

您可以从网络连通、客户端版本、配置这三个方向进行排查...您的客户端首次接入消息队列Kafka版,通常会被以下三个问题困扰: 网络连通 客户端版本 配置 您可以从上述三个方向,一步一步排查,基本上可以解决99%的问题。
来自: 阿里云 >帮助文档

如何选择实例规格?

消息队列Kafka版提供两种实例规格:标准版和专业版。您可以根据自建迁移情况选择实例规格。标准版 流量规格:集群流量的总量÷3(优化) 磁盘大小:流量均值×存储时长×3(备份) Topic数量:根据实际业务需求 说明...
来自: 阿里云 >帮助文档

升级Broker可能产生哪些影响?

升级过程中,会逐个重启消息队列Kafka版 集群中所有的Broker。在重启Broker的过程中服务不会中断,但是从每个Broker重启完成之后的5分钟内消费的分区消息可能会发生乱序(设置为顺序消息的,则不会乱序,而是短暂的...
来自: 阿里云 >帮助文档

删除了Consumer Group还会收到堆积告警?

等待位点过期 消息队列Kafka版的消费位点保存在一个内部Topic里面,无法直接删除。位点在超过消息保留期限后仍然没有任何更新,就会被过期清理。注意 较早购买的用户,没有开启这个清理机制,请先在实例详情页,升级...
来自: 阿里云 >帮助文档

不同VPC之间是否支持互连?

全网通过IP地址唯一性管理,避免地址冲突问题。用户不需要额外配置,网络通过控制器实现多节点、多级路由的自动转发与学习,实现全网的路由快速收敛。低时延高速率 云企业网提供低延迟、高速率的网络传输能力。本地...
来自: 阿里云 >帮助文档

消费端从服务端拉取不到消息或拉取消息缓慢

登录消息队列Kafka版控制台查询消息。如果能查询到消息,请继续尝试以下步骤。在监控报警页面,查看消费流量是否已达到网络带宽。如果消费流量已经达到网络带宽,您需要扩充网络带宽。检查Topic中是否存在单个消息的...
来自: 阿里云 >帮助文档

哪里可以找到发送最佳实践?

发布者最佳实践。请参见发布者最佳实践。
来自: 阿里云 >帮助文档

Topic数量和分区数量的对应关系

1个Topic对应16个分区。在默认分区数的基础上,每增购1个Topic,对应增加16个分区。例如,您购买了Topic数量为50、流量规格为20 MB/s、默认分区数为400的实例,那么当您增购10个Topic后,该实例对应增加160个分区,...
来自: 阿里云 >帮助文档

实例的地域或网络属性无法变更

如需变更实例的地域或网络属性,请释放实例,并重新购买。实例购买部署之后,其地域和网络属性与物理资源紧密结合,无法变更。如需变更实例的地域或网络属性,请释放实例,并重新购买。
来自: 阿里云 >帮助文档

生产者会建立多少个到Broker的连接?

每个生产者通常会建立2个到Broker的TCP连接。每个生产者通常会建立2个到Broker的TCP连接,一个TCP连接用于更新元数据,一个TCP连接用于发送消息。更多信息,请参见How are TCP Connections managed by kafka-clients...
来自: 阿里云 >帮助文档

如何监控开源Apache Kafka?

本文为您介绍监控开源Apache Kafka的解决方案。如果您需要监控开源Apache Kafka,请参见以下解决方案: How to Monitor Kafka Monitoring Kafka performance metrics
来自: 阿里云 >帮助文档

Consumer Group规格是多少?

Consumer Group规格默认为Topic规格的2倍。Consumer Group规格默认为Topic规格的2倍。例如,某个实例的Topic规格为50个,则该实例下最多能创建100个Consumer Group。如需升级Consumer Group规格,您可升级Topic规格...
来自: 阿里云 >帮助文档

使用客户端发送消息后,如何确定是否发送成功?

如果回调成功则说明消息发送成功。大部分客户端在发送之后,会返回Callback或者Future,如果回调成功,则说明消息发送成功。此外,您还可以在控制台通过以下方式确认消息发送是否正常: 查看Topic的分区状态,可以...
来自: 阿里云 >帮助文档

MNS可以做什么

将消息服务MNS用作工作队列,其中每条消息代表一项任务,需要通过一个流程来完成。一台或多台ECS可以从队列中读取并执行任务。将业务流程中重要事件的通知保存在消息服务MNS中,每个事件在队列中都有一条对应的消息...
来自: 阿里云 >帮助文档

Java客户端设置回调是否会影响消息发送的速度?

取决于回调里的处理耗时以及max.in.flight.requests.per.connection的设置。Java客户端设置回调是否会影响消息发送的速度取决于: 回调里的处理耗时:为减少回调里的处理耗时,不要过于频繁地在回调里面做耗时的处理...
来自: 阿里云 >帮助文档

专业版实例附赠1倍的Topic

专业版实例的可用Topic数为购买Topic数的两倍。专业版实例的可用Topic数=购买Topic数×2。例如,您购买了Topic数量为50的专业版实例,那么该实例实际可用的Topic数为100。
来自: 阿里云 >帮助文档

父账号能看到监控信息,子账户看不到监控信息

子账号没有被授予查看监控信息的权限。父账号给子账号授权AliyunCloudMonitorReadOnlyAccess权限后,子账号即可看到监控信息。操作步骤,请参见RAM主子账号授权。
来自: 阿里云 >帮助文档

支持电话语音通知吗?

IP、分布式关系型数据库服务、分析型数据库、高速通道、开放缓存服务、日志服务、视频点播服务、数据传输服务、消息队列、云数据库 MongoDB 版等。...登录 阿里云官网,单击页面右上方 控制台 进入管理控制台后,单击...
来自: 阿里云 >帮助文档

哪里可以找到消费最佳实践?

订阅者最佳实践。请参见订阅者最佳实践。
来自: 阿里云 >帮助文档

如何查看哪些IP在消费消息?

在控制台根据Consumer Group查看消费状态。在控制台根据Consumer Group查看消费状态,单击详情,可以看到各个分区的owner 进而看到对应的IP。如果看到owner为空,说明客户端不在线或者处于Rebalance中。
来自: 阿里云 >帮助文档

消费端挂载NFS云盘是否会影响消费端处理速度?

这解释了为什么消费者个数多了,性能反而下降。这一方面,可以考虑采用云盘,给每台消费端处理机挂载自己的云盘,独立存储,这样增加消费端不会因为争抢NFS而降低性能。挂载云盘的存储是各自独立的。如果您需要把...
来自: 阿里云 >帮助文档

经典网络是否必须要选择172.16.0.0/12网段?

不是必须,但使用172.16.0.0/12网段的配置最简单。不是,但是使用172.16.0.0/12网段的配置最简单。如需选择其他网段,请参见 ClassicLink概述进行配置。
来自: 阿里云 >帮助文档

如何确保在MNS中存储的数据的可靠性?

将所有队列和消息存储在阿里云高可靠、高可用的数据中心组成的网络中。所有消息冗余地存储在多台服务器上,当某台服务器出现问题时,冗余数据将会被自动拷贝至其他服务器;这意味着单台服务器不可用或网络故障都不会...
来自: 阿里云 >帮助文档

人脸聚类相关问题

人脸聚类需要什么 Project 类型?图片标准型。为什么无法生成人脸分组?生成分组需要有如下前提: 使用 IndexImage 将照片添加到媒体集 Set。同...更佳方案,每次 IndexImage 时,将其对应的 Set 推入一个延迟队列。...
来自: 阿里云 >帮助文档
< 1 >
共有1页 跳转至: GO

新品推荐

你可能感兴趣

热门推荐

切换为移动版

企典文档内容 商标申请信息 商标注册信息 云计算服务器排行榜 大数据产品榜单