在使用云消息队列 Kafka 版时，客户端可能报错，您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权（sasl.mechanisms）...
网络限制 Java SDK V2.x.x.Final：仅支持通过VPC网络访问 云消息队列 RocketMQ 版，不支持经典网络访问。重要 若您使用存量 云消息队列 RocketMQ 版 实例并通过经典网络访问，请勿将Java SDK升级到V2.x.x.Final版本，否则将无法访问 云消息...
鉴于消息同步的消息量以及网络带宽瓶颈，消息同步可能会产生一定的时间延迟。前提条件 云消息队列 RabbitMQ 版 源实例、源Vhost、源Exchange、源Queue以及目标实例、目标Vhost、目标Exchange、目标Queue已创建并可用。具体操作，请参见：...
全球消息路由功能可用于跨地域间的消息同步，通过路由规则将消息从源实例的Topic中同步到目标实例的Topic，并支持过滤规则，按照指定的Tag将消息过滤后再进行同步。在容灾备份或异地多活场景下，您可以创建全球消息路由任务，确保跨地域间...
Kafka商业模式 功能集 功能 功能描述 参考文档 Serverless版本 升降配管理 在云消息队列 Kafka 版控制台完成实例升配或降配，配置项包括规格类型、实例类型、发送能力预留和订阅能力预留等。升级实例配置 降低实例配置 弹性策略 V3系列...
详细信息 给自己发信息，可以在【消息界面】搜索【文件小助手】或者【自己的钉钉号】，然后给自己发信息、文件。在聊天中遇到重要的信息想转发给自己，可以对消息进行转发，【手机端长按消息，电脑端将鼠标移到消息点击三个点图标】，点击...
当客户端使用SDK无法收发消息或无法连接实例时，您可以使用Kafka的自检工具对实例的健康状态进行自检，检查网络是否连通、实例状态是否异常。若实例无异常，请检查网络是否连通、实例状态是否异常、客户端代码配置是否正确以排除您的客户端...
MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息，云消息队列 MQTT 版 支持将该条消息数据导出至其他阿里云产品，并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的 云消息队列 RocketMQ 版 数据互通...
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格的实例都有明确的 SLA保障，您购买实例后即可保证消息收发TPS、消息存储、网络吞吐等指标达到规格规定的能力。您无需担心实例性能问题，但实际生产环境中仍需要关注...
修复了消息消费失败发回（sendMessageBack）的问题。修复了客户端Topic级别消息缓存限制未生效的问题。ons-client-1.8.8.Final 1.8.7.4.Final 发布时间 发布内容 下载 2021-02-08 功能优化 修复了特殊场景下顺序消息消费延迟的问题。修复了...
应用与 云消息队列 RabbitMQ 版 完成Connection建立大约需要15个TCP报文交互，因而会消耗大量的网络资源和 云消息队列 RabbitMQ 版 资源。大量的Connection会对 云消息队列 RabbitMQ 版 造成巨大压力，甚至触发 云消息队列 RabbitMQ 版 SYN...
重发指定Message ID的死信消息，使该消息能够被Consumer再次消费。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则...
消息服务MNS 将所有队列和消息存储在阿里云高可靠、高可用的数据中心组成的网络中。所有消息冗余地存储在多台服务器上，当某台服务器出现问题时，冗余数据将会被自动拷贝至其他服务器；这意味着单台服务器不可用或网络故障都不会对队列中...
不使用 网络配置 专有网络：通过专有网络VPC将Kafka消息投递到Elasticsearch。公网：通过公网将Kafka消息投递到Elasticsearch。公网 VPC 选择VPC ID。仅当 网络配置 为 专有网络 时需配置此参数。vpc-bp17fapfdj0dwzjkd*交换机 选择vSwitch...
如果需要同时在VPC网络和公网接入 云消息队列 Kafka 版，您需要购买并部署公网/VPC实例。前提条件 已授予 云消息队列 Kafka 版 访问其他云服务资源的权限。具体信息，请参见 获取访问授权。已搭建VPC网络。具体操作，请参见 创建和管理专有...
本文介绍如何创建使用AnalyticDB Sink Connector，您可通过AnalyticDB Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至AnalyticDB的表中。前提条件 详细步骤，请参见 创建前提。步骤一：创建目标服务资源 创建 云原生...
如果仅需要在VPC网络接入 云消息队列 Kafka 版，您可以购买并部署VPC实例。前提条件 已授予 云消息队列 Kafka 版 访问其他云服务资源的权限。具体信息，请参见 步骤一：获取访问授权。已搭建VPC网络。具体操作，请参见 创建和管理专有网络...
在使用 云消息队列 MQTT 版 前，需理解该产品和MQTT协议所涉及的基本概念和术语。基本概念 实例（Instance）创建购买 云消息队列 MQTT 版 服务的实体单元，每个 云消息队列 MQTT 版 实例都对应一个全局唯一的服务接入点URL。使用 云消息...
本文介绍如何创建使用MaxCompute Sink Connector，您可以通过MaxCompute Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至MaxCompute的表中。前提条件 详细步骤，请参见 创建前提。注意事项 如需使用MaxCompute分区...
同步发送 原理 同步发送是指消息发送方发出一条消息后，会在收到服务端同步响应之后才发下一条消息的通讯方式。应用场景 此种方式应用场景非常广泛，例如重要通知邮件、报名短信通知、营销短信系统等。示例代码 import ...
绝大多数情况下，消息是不重复的。作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，无法保证消息不重复，但是能保证消息不丢失。
同步发送 原理 同步发送是指消息发送方发出一条消息后，会在收到服务端返回响应之后才发下一条消息的通讯方式。应用场景 此种方式应用场景非常广泛，例如重要通知邮件、报名短信通知、营销短信系统等。示例代码 import java.util.Date;...
本文介绍如何在 云消息队列 Kafka 版 控制台完成实例升配，升级的配置项包括规格类型、流量规格、磁盘容量及分区规格等。前提条件 实例处于 服务中 或 未部署 状态。实例中没有进行中的Topic引流任务。注意事项 升级实例配置会引发集群逐台...
通过数据传输服务DTS（Data Transmission Service），您可以将自建MySQL同步至 云消息队列 Kafka 版，扩展消息处理能力。前提条件 您已完成以下操作：自建MySQL数据库且数据库版本为5.1、5.5、5.6、5.7或8.0版本。购买并部署 云消息队列 ...
相关链接 根据接入 云消息队列 Kafka 版 网络类型，购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 VPC接入 和 公网和VPC接入。创建收发消息使用的Topic和 Group。具体操作，请参见 步骤三：创建资源。公网/VPC实例的默认SASL用户...
说明 为了避免因带宽不足触发网络限制，云消息队列 Kafka 版 会根据您选择的实例规格，评估出最佳带宽大小，请您根据界面提示，按一定倍数购买公网流量。降低后的分区数量不能低于实际使用的分区数量。在专业版（高写版）/专业版（高读版）...
云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时，云消息队列 RocketMQ 版 仅4.0系列实例支持消息流入或流出规则，5.0系列实例不支持。...
说明 tcpclean 消息代表客户端网络层连接的真实断开。对应的，disconnect 消息仅仅代表客户端是主动发送了下线报文。受限于客户端的实现，有时候客户端异常退出会导致 disconnect 消息并没有正常发送。因此判断客户端下线请使用 tcpclean ...
创建云手机后，您可以在云手机控制台通过WebRTC远程连接云手机。背景信息 WebRTC(Web Real-Time Communications)是一项实时通讯技术，它允许网络应用或者站点，在不借助中间媒介的情况下，建立浏览器之间点对点（Peer-to-Peer）的连接，...
本文介绍如何进一步提高您与 消息服务MNS 服务之间的网络链路上的安全性。背景信息 消息服务MNS 提供在公网HTTPS上进行消息加密传输的服务。对于包含敏感信息的消息，进一步提高您与阿里云服务之间的网络链路上的安全性，目前有以下两种...
上行消息、下行回执报告消息 手机号码验证通过后，单击 WebHook设置，勾选需要订阅的消息。勾选 HTTP协议，填写状态报告回调地址和消息上行回调地址。地址示例：http://push.example.com/contextpath/receive.do 勾选 消息队列监控。模板...
当使用 云消息队列 Kafka 版 进行消息收发时，您需要在已成功部署的Kafka实例中创建Topic和Group资源。生产者需要将消息发送至指定Topic，消费者通过订阅Topic获取消息进行消费。消费者消费消息时，需要指定Group订阅对应的Topic。Group和...
解决直播中手机端互发消息和消息内容的安全审核问题，同时低成本保存消息。部署架构图 选用的产品 云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 是由阿里巴巴自研并捐赠给Apache基金会，并与开源社区共建的消息中间件，该产品服务于阿里...
前提条件 创建消息队列RocketMQ版5.0系列实例 创建服务关联角色 角色名称：AliyunServiceRoleForRMQMigration 权限策略：AliyunServiceRolePolicyForRMQMigration 权限说明：允许 云消息队列 RocketMQ 版 使用该角色获取访问专有网络VPC的...
音视频通信解决方案是由阿里云 云消息队列 MQTT 版 和音视频通信RTC联合推出的有助于快速搭建各种实时通信场景产品，譬如在线音视频会议、1对1语音通话应用的解决方案。本文将详细描述该解决方案的系统架构、数据流设计以及相关注意事项。...
单个原子消息事件的数据大小需要严格控制，如果单条消息过大容易造成网络传输层压力，不利于异常重试和流量控制。生产环境中如果需要传输超大负载，建议按照固定大小做报文拆分，或者结合文件存储等方法进行传输。消息中转时做好不可变设计...
消息回查：由于网络闪断、生产者应用重启等原因，导致某条事务消息的二次确认丢失，云消息队列 RocketMQ 版 服务端通过扫描发现某条消息长期处于“半事务消息”时，需要主动向消息生产者询问该消息的最终状态（Commit或是Rollback），该...
搭建Link WAN网络服务需要有网关和通信模组，本文介绍如何在物联网络管理平台添加网络、分享网络并通过凭证入网。背景信息 网关和通信模组的获取方式有如下两种：移植SDK到网关与通信模组上，并且 购买Link WAN密钥 安装后使用。移植教学可...
背景信息 智能接入网关SAG（Smart Access Gateway）APP是智能接入网关的软件客户端形态，您在电脑、手机等移动终端安装SAG APP客户端后，可一键连接企业内网。更多信息，请参见 SAG APP介绍。架构图 操作步骤 步骤一：创建并配置SAG APP ...