BatchPeekMessage
Name Value API BatchPeekMessage RAM授权操作 mns:BatchPeekMessage 资源 acs:mns:$region:$accountid:/queues/$queueName/messages 使用说明 该接口用于消费者批量查看消息，一次最多查看16条消息。BatchPeekMessage与...
CreateTopic
http://$AccountId.mns.cn-hangzhou.aliyuncs.com/topics/$TopicName 错误码 错误码 错误消息 HTTP状态码 描述内容 TopicAlreadyExist The topic you want to create is already exists.409 同名主题已存在，且请求属性与原有主题属性不同...
接口说明
通用错误码 错误码 原因 解决办法 40000001 身份认证失败 检查使用的令牌是否正确，是否过期。40000002 无效的消息 检查发送的消息是否符合要求。40000004 空闲超时 确认是否长时间（10秒）没有发送数据到服务端。40000005 请求数量过多 ...
专家一对一服务
当您在使用数字证书管理服务过程中遇到问题时，您可以采用专家协助自助服务（在线网页、钉钉客户端）或付费专家远程处理服务解决问题。本文介绍如何使用专家一对一服务功能。服务介绍 专家一对一服务 服务说明 服务时间 专家协助客户自助...
API错误码
调用短信服务API接口失败时会返回错误码，请根据错误码和错误信息排查问题。错误码（Code）错误信息（Message）原因及解决方案 isv.SMS_SIGNATURE_SCENE_ILLEGAL 签名和模板类型不一致 原因：模板和签名类型不一致。错误示例：用验证码签名...
短信发送状态回执错误码
解决方案：请确认接口的版本号，短信服务的API版本号（Version）为2017-05-25。InvalidAction.NotFound 未找到指定的API，请检查您的URL和方法 原因：参数 Action 中指定的接口名错误。解决方案：请在参数 Action 中使用正确的接口地址和...
消息处理时长自适应
背景信息 消息服务MNS 的规范中，每条消息都有个默认的VisibilityTimeout，Worker在接收到消息后，Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息，那么消息就有可能被其他Worker接收到并处理。Timeout计时的好处在于消息...
配置消息监控告警实现风险预警
背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格的实例都有明确的 SLA保障，您购买实例后即可保证消息收发TPS、消息存储等指标达到规格规定的能力。您无需担心实例性能问题，但实际生产环境中仍需要关注实际的业务...
配置消息监控告警实现风险预警
背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格的实例都有明确的 SLA保障，您购买实例后即可保证消息收发TPS、消息存储、网络吞吐等指标达到规格规定的能力。您无需担心实例性能问题，但实际生产环境中仍需要关注...
消息服务MNS的订阅成功后收不到消息
问题描述 消息服务MNS的订阅成功后收不到消息，并且在日志中查不到相关记录。问题原因 可能是由于订阅时配置了 FilterTag 参数。该参数描述了订阅中消息过滤的标签，标签一致的消息才会被推送。解决方案 请参考如下步骤进行排查。检查消息...
错误处理
Message 为错误消息，提示错误的原因和解决办法；RequestId 为请求的唯一ID。（注意：在使用接口调用时，此参数在Http Header: x -ca-request-id 中）有少量场景，网关层报错，其错误码和错误代码形式如下：x-ca-error-code:D504TO x-ca-...
总览
消息服务MNS-Topic 如果您打开 消息服务MNS-Topic 开关，当报警发生时，会将报警信息发送至消息服务的主题。您需要设置消息服务的地域和主题。关于如何创建主题，请参见 创建主题。说明 单击 高级设置，可设置该参数。函数计算 如果您打开 ...
Control Center设置告警
因此，如果不干净的选举数量大于0，可以查询Broker日志以确定为什么Leader被重新选举，并寻找警告或错误消息。建议将brokers配置参数设置为unclean.leader.election.enable=false，以便同步副本集之外的副本永远不会被选为Leader，创建触发...
其他常见问题
基于消息的任务中，业务应用未收到消息任务 排查思路 查看任务调度控制台任务配置的消息事件码是否与消息控制台配置的一致。若消息时间码一致，查看消息控制台配置的消息任务的 Topic 是否为 TP_F_SC，否则修改为 TP_F_SC。若 Topic 配置...
Filebeat发送失败问题
问题现象 在 云消息队列 Kafka 版 控制台 的 Topic 管理 页面，您已成功创建Topic，但使用Filebeat向该Topic发送消息却出现 Request was for a topic or partition that does not exist on this broker.的错误提示。可能原因 Filebeat向...
可观测性体系概述
作为一款典型的分布式中间件产品，云消息队列 RocketMQ 版 被广泛应用于业务核心链路中，每条消息都关联着核心业务数据的变化，通过可观测能力及时发现问题、定位问题、解决问题对于业务运行是一项重要的保障能力。本文介绍 云消息队列 ...
版本说明
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
公共云基础服务说明书
订阅支持 阿里云针对购买云产品的客户，将提供消息订阅基础支持，目前提供的消息种类主要包含产品消息、故障消息、服务消息、活动消息几大类，客户可根据需要登录阿里云官网进入 消息中心 设置订阅或查看消息。3.服务SLA 电话/官网在线咨询...
发布者最佳实践
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future...
使用JDBC Connector同步MySQL数据
本文介绍如何创建JDBC Connector，将MySQL和 云消息队列 Kafka 版 的数据进行互相同步。前提条件 已开通事件总线EventBridge并授权。已开通对象存储OSS服务并创建存储空间（Bucket）。更多信息，请参见 控制台创建存储空间。已开通...
发送消息时返回“MQClientException:No route info of...
问题现象 使用TCP协议SDK发送消息时，云消息队列 RocketMQ 版 服务端返回如下错误：Caused by:com.aliyun.openservices.shade.com.alibaba.rocketmq.client.exception.MQClientException: No route info of this topic 可能原因 代码中设置...
错误码
在调用API接口过程中，若服务端返回结果中包含错误信息，则表示调用API接口失败。您可以根据本文错误码对照表查找对应的解决方法。概述 当API请求发生错误的时候，服务端会返回错误信息，包括HTTP的Status Code和响应Body中的具体错误细节...
常见问题
客户端报错 使用云消息队列 Kafka 版时客户端的报错及解决方案 使用云消息队列 Kafka 版时出现“Not authorized to access group”的错误信息 网络问题 无法ping通云消息队列 Kafka 版的接入点 不在同一可用区内的ECS实例如何访问云消息...
返回结果
返回的消息体中是具体的错误代码及错误信息。另外还包含一个全局唯一的请求ID：RequestId和一个您本次请求访问的站点ID：HostId。调用方找不到错误原因，可以联系阿里云客服，提供HostId和RequestId以便客服尽快帮您解决问题。
最佳实践概览
ChatApp 消息服务（ChatApp Message Service）是阿里云为全球企业打造的一款高效触达用户的消息引擎，通过与WhatsApp平台合作，使您轻松地使用WhatsApp平台的消息服务，触达全球10亿+用户，通过丰富的消息类型，提升您与客户的互动体验，...
依赖服务
外部调用与消息调用 概览 在 概览 页签可以查看目标地址/服务/消息的请求数、错误数、平均耗时，以及对应的时序曲线。调用链分析 调用链分析功能基于已存储的全量链路明细数据，通过自由组合筛选条件与聚合维度进行实时分析，可以满足不同...
依赖服务
依赖服务详情 外部调用与消息调用 概览 在 概览 页签可以查看目标地址/服务/消息的请求数、错误数、平均耗时的统计情况，以及慢调用的时序曲线。调用链分析 调用链分析功能基于已存储的全量链路明细数据，通过自由组合筛选条件与聚合维度...
使用云消息队列 Kafka 版时客户端的报错及解决方案
在使用云消息队列 Kafka 版时，客户端可能报错，您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权（sasl.mechanisms）...
在线教育视频直播
场景描述 适用于在线教育的视频直播场景，通过阿里云视频直播服务实现移动端的推拉流能力，同时移动端利用 云消息队列 MQTT 版 实现发送和接收消息，在消息转发时利用内容安全服务对消息内容进行审核。发送的消息可以存储在表格存储中。...
什么是云消息队列 Confluent 版？
云消息队列 Confluent 版 全托管服务可以解决以下痛点：正版全托管云上企业级Kafka服务：云消息队列 Confluent 版 提供正版Confluent Platform license，并且只需较低成本即可享受。搭建Kafka集群复杂性的问题：使用阿里云商业版Confluent...
QueueHasDiffField
问题现象 使用 云消息队列 RabbitMQ 版 客户端连接 云消息队列 RabbitMQ 版 服务端时，报QueueHasDiffField类型错误。例如QueueHasDiffField[OAutoDelete=false&NAutoDelete=true;说明 报错中O开头的参数的属性值为要调用的Queue的参数的已...
错误码
解决方案：请提交 工单，或联系Dataphin的支持人员协助处理。DPN.Bbox.MetaCenterServiceError 错误原因：元数据服务不可用。解决方案：请提交 工单，或联系Dataphin的支持人员协助处理。DPN.Bbox.ModelNotFound 错误原因：根据模型ID查询...
迁移上云操作
前提条件 创建消息队列RocketMQ版5.0系列实例 创建服务关联角色 角色名称：AliyunServiceRoleForRMQMigration 权限策略：AliyunServiceRolePolicyForRMQMigration 权限说明：允许 云消息队列 RocketMQ 版 使用该角色获取访问专有网络VPC的...
ExchangeHasDiffFields
问题现象 使用 云消息队列 RabbitMQ 版 客户端连接 云消息队列 RabbitMQ 版 服务端时，报ExchangeHasDiffFields类型错误。例如ExchangeHasDiffFields[ODurable=true&NDurable=false;说明 报错中O开头的参数的属性值为要调用的Exchange的...
错误码列表
如果成功调用 云消息队列 MQTT 版 的OpenAPI，则会返回给客户端ResponseCode=200；如果调用失败，会返回对应的异常错误码以及描述信息。您可以根据以下异常信息对照表查找对应的解决方法。Token相关错误码 HttpCode 错误码 错误信息 描述 ...
注意要点
这种情况下客户端看到的现象是服务端间歇性推送消息，并且重启消费者后消息恢复，建议通过增强消费者的消费能力解决。消费者提交的ack如果不在指定时间内，则触发消费重试。消息将会被重新投递，最多重试16次。若重试16次还未成功，则消息...
使用MongoDB Connector连接MongoDB数据库
解决方法：在消息流入任务详情页面，单击 基础信息 区域的 诊断链接，即可跳转到Connector监控页面，可以看到Tasks运行失败的详细错误信息。场景二：Kafka Connect退出 错误信息：Kafka connect exited!Please check the error log/opt/...
基于Flink的资讯场景实时数仓
部署架构图 选用的产品 云消息队列 Kafka 版 云消息队列 Kafka 版 是阿里云基于Apache Kafka构建的高吞吐量、高可扩展性的分布式消息队列服务，广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等，是大数据生态中不可或缺的...
直播公告（2020~2022年）
构建基于Ingress的全链路灰度能力 2022-11-24 基于OpenSergo标准构建Spring Cloud Alibaba流量路由能力 流量路由是微服务治理的核心场景之一，MSE通过OpenSergo构建云原生趋势下的微服务治理标准，使异构微服务能够使用统一的服务协议与...
事务消息
事务消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...
- 产品推荐
- 这些文档可能帮助您