您可通过配置 云消息队列 MQTT 版 的客户端上下线通知规则,将获取的MQTT客户端上下线事件数据导出至其他阿里云产品。该方法为异步上下线通知。本文介绍客户端上下线通知的原理、应用场景、使用限制以及 云消息队列 MQTT 版 与其他阿里云...
云消息队列 Kafka 版 可以作为Input接入Filebeat。本文说明如何在VPC环境下通过Filebeat从 云消息队列 Kafka 版 消费消息。背景信息 在开始本教程前,请确保您已完成以下操作:购买并部署 云消息队列 Kafka 版 实例。具体操作,请参见 VPC...
包年包月或按量付费计费方式下,消息收发计算规格为 云消息队列 RocketMQ 版 的必选计费项,云消息队列 RocketMQ 版 根据消息收发TPS上限提供不同的计算规格,并按照规格大小和购买时长计算费用。计算规格说明 计算规格能力约束 消息收发...
本文汇总了使用 云消息队列 Kafka 版 实例时的常见问题。计费问题 为什么购买了按量付费实例后不使用也要收费?为什么按流量峰值收费?按流量峰值收费的依据是什么?为什么额外增加分区要收费?我使用的Connector组件如何计费?客户端报错 ...
本产品(云消息队列 Kafka 版/2019-09-16)的OpenAPI采用 RPC 签名风格,签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK,开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用...
实例是用于 云消息队列 RocketMQ 版 服务的虚拟机资源,会存储消息主题(Topic)和客户端ID(Group ID)信息。使用 云消息队列 RocketMQ 版 进行消息收发,必须先创建 云消息队列 RocketMQ 版 实例。本文介绍如何在 云消息队列 RocketMQ 版...
错误码 错误描述 HTTP状态码 建议处理方式 AccessDenied The OwnerId that your Access Key Id associated to is forbidden for this operation.403 权限不足,请检查AccessKey ID和AccessKey Secret配置是否正确。若您使用账号为RAM用户,...
事务超时机制 云消息队列 RocketMQ 版 事务消息的生命周期存在超时机制,即半事务消息被生产者发送服务端后,如果在指定时间内服务端无法确认提交或者回滚状态,则消息默认会被回滚。事务超时时间,请参见 参数限制。不支持多个sendReceipt...
bindings 配置队列与交换机绑定的数组,包含绑定信息。concurrency 设置监听器容器(Listener)的并发线程数。errorHandler 为监听方法抛出的异常配置错误处理器。exclusive 启用队列的独占模式,指消费者独占队列,其他消费者无法从该队列...
云消息队列 Kafka 版 可以作为Input接入Logstash。本文说明如何在公网环境下通过Logstash从 云消息队列 Kafka 版 消费消息。前提条件 在开始本教程前,请确保您已完成以下操作:购买并部署 云消息队列 Kafka 版 实例。具体操作,请参见 ...
随着时间的积累,云消息队列 Kafka 版 中的日志数据会越来越多。当您需要查看并分析庞杂的日志数据时,可通过阿里云Logstash将 云消息队列 Kafka 版 中的日志数据导入阿里云Elasticsearch,然后通过Kibana进行可视化展示与分析。本文介绍将...
云消息队列 Kafka 版 可以作为Input接入Logstash。本文说明如何在VPC环境下通过Logstash从 云消息队列 Kafka 版 消费消息。前提条件 在开始本教程前,请确保您已完成以下操作:购买并部署 云消息队列 Kafka 版 实例。具体操作,请参见 VPC...
} } 事务回查机制说明 发送事务消息为什么必须要实现回查Check机制?当半事务消息发送完成,但本地事务返回状态为 TransactionStatus.Unknow,或者应用退出导致本地事务未提交任何状态时,从Broker的角度看,这条半事务消息的状态是未知的...
新零售电子价签解决方案由阿里云 云消息队列 MQTT 版 推出,通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项,其他类似行业可参考该方案...
云消息队列 Kafka 版 可以作为Input接入Filebeat。本文说明如何在公网环境下通过Filebeat从 云消息队列 Kafka 版 消费消息。背景信息 在开始本教程前,请确保您已完成以下操作:购买并部署 云消息队列 Kafka 版 实例。具体操作,请参见 ...
在创建并部署 云消息队列 Kafka 版 实例后,您可以使用 云消息队列 Kafka 版 控制台直接发送消息,快速测试服务端是否正常。前提条件 您已创建并部署 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。操作流程 快速测试 云消息队列 ...
Batch机制,云消息队列 Kafka 版 Producer端主要通过两个参数进行控制:batch.size:发往每个分区(Partition)的消息缓存量(消息内容的字节数之和,不是条数)。达到设置的数值时,就会触发一次网络请求,然后Producer客户端把消息批量发...
当使用 云消息队列 Kafka 版 进行消息收发时,您需要在已成功部署的Kafka实例中创建Topic和Group资源。生产者需要将消息发送至指定Topic,消费者通过订阅Topic获取消息进行消费。消费者消费消息时,需要指定Group订阅对应的Topic。Group和...
本文介绍基于 云消息队列 RabbitMQ 版 当前日志快速查询和分析问题的方法。当您遇到消息不符合预期、消费异常、消息堆积时,通过该方法可以帮助您高效识别出异常、保证业务正常运行。前提条件 推送 云消息队列 RabbitMQ 版 实例的消息操作...
云消息队列 RocketMQ 版 作为金融级的可靠业务消息中间件,在消息投递处理机制的设计上天然支持可靠传输策略,通过完整的确认和重试机制保证每条消息都按照业务的预期被处理。了解 云消息队列 RocketMQ 版 的消息确认机制以及消费重试策略...
您可以使用 云消息队列 RabbitMQ 版 的日志管理功能将 云消息队列 RabbitMQ 版 实例的消息操作日志推送到日志服务。当消息的发送、消费、确认出现异常时,您可在日志服务查询并分析消息的操作日志,进行异常诊断。前提条件 创建 云消息队列...
更新云消息队列 RocketMQ 版实例的基本信息和规格配置。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API,用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成,消息收发的核心数据链路中严禁依赖 OpenAPI 实现,否则可能会导致...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 消息服务MNS 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已创建 消息服务MNS 队列。具体步骤,...
创建云消息队列 RocketMQ 版5.x系列实例。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API,用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成,消息收发的核心数据链路中严禁依赖 OpenAPI 实现,否则可能会导致链路产生风险...
} } 事务回查机制说明 发送事务消息为什么必须要实现回查Check机制?当步骤1中半事务消息发送完成,但本地事务返回状态为 LocalTransactionState.UNKNOW,或者应用退出导致本地事务未提交任何状态时,从Broker的角度看,这条Half状态的消息...
} } Push方式(批量消费)重要 配置 云消息队列 RocketMQ 版 的批量消费功能,请升级TCP Java SDK到1.8.7.3或以上版本,详细版本说明和获取方式,请参见 Java SDK版本说明。import com.aliyun.openservices.ons.api.Action;import ...
本产品(云消息队列 RocketMQ 4.0 版/2019-02-14)的OpenAPI采用 RPC 签名风格,签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK,开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能...
} } 事务回查机制说明 发送事务消息为什么必须要实现Check机制?当步骤1半事务消息发送完成,但本地事务返回状态为 TransactionStatus.Unknow 时,亦或是应用退出导致本地事务未提交任何状态时,从Broker的角度看,这条半状态的消息的状态...
注意事项 云消息队列 MQTT 版 通过配置的流入规则和 云消息队列 RocketMQ 版 进行跨云产品的消息交互时,若 云消息队列 RocketMQ 版 的服务端进行升级,则在升级期间,可能会造成 云消息队列 MQTT 版 客户端消费消息延迟。产品升级动态,请...
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务,将 云消息队列 RabbitMQ 版 中的数据快速导入至 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买和...
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务,将 云消息队列 MQTT 版 中的数据快速导入至 云消息队列 Kafka 版 实例中。前提条件 您已购买 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流出任务,将 云消息队列 RabbitMQ 版 的数据导出至函数计算。前提条件 您已购买 云消息队列 RabbitMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已开通函数...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务,将指定 云消息队列 Kafka 版 实例中的数据导出至其他的 云消息队列 Kafka 版。前提条件 您已购买并部署 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已开通函数计算服务,具体...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流入任务,将 云消息队列 RocketMQ 版 的数据快速导入至 云消息队列 Kafka 版。前提条件 您已购买Kafka实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买和部署实例。您已...
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务,将指定 云消息队列 Kafka 版 实例中的数据快速导入至另外的 云消息队列 Kafka 版 实例中。前提条件 您已购买 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已开通函数计算服务,具体...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流入任务,将 消息服务MNS 中的数据快速导入 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买和部署实例。...
本文介绍如何在 云消息队列 MQTT 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 MQTT 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已购买并部署 云消息队列 Kafka 版 ...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务,以实现将 云消息队列 RocketMQ 版 的消息流出至 消息服务MNS。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已...