云消息队列 Kafka 版 不再支持按照Topic规格购买实例。若您的已有实例是按照Topic规格购买 Topic说明如下：不同的流量规格对应不同的Topic或分区数量上限。在默认分区数的基础上，每增购1个Topic，对应增加16个分区。例如，您购买了Topic...
本文以智能灯和手机App连接为例，基于物联网平台的Topic消息路由服务，构建一个M2M设备间通信架构。背景信息 智能灯控制流程如下图：操作步骤 在 物联网平台控制台，为智能灯设备创建产品和设备，定义功能等。具体操作，请参见 创建产品、...
Topic总数（分区总数）太多会使集群性能和稳定性能急剧下降。云消息队列 Kafka 版 的存储和协调机制是以分区为粒度的，分区数太多，会导致存储碎片化严重，集群性能和稳定性都会急剧下降。
自2022年8月26日起，消息队列Kafka版 不再支持按照Topic规格购买实例。若您的已有实例是2022年8月26日之前购买的，规格内包含的Topic数和分区数如下所示：表 1.标准版（高写版）流量规格内预包含Topic、Group数（公共云）流量规格 网卡读...
问题现象 发送消息到某个Topic后，该Topic下部分分区消息比较多，部分分区消息少，甚至没有。分区中消息量可以在 Topic详情 页面的 分区状态 页签查看，位点数即是消息数。以下图为例，分区 2 消息比较多，其他分区消息少甚至没有，消息...
Group 没有消费过该Topic分区的消息。如果 Group 没有消费过某Topic分区的消息，那么 Group 对应的Topic分区的最近消费时间显示为1970。
failed to get master store addr for topic aliyun_sz_ecs_rdsr*y-1-0 问题原因 订阅通道的消费时间点设置早于实际消费时间。解决方案 数据订阅的前提是SDK配置 usePublicIp=true 参数，确认不是这个问题后进行下一步排查。说明 数据订阅...
'{{instanceId}}' Outputs:updateTopicAndTags:Type:List ValueSelector:.Data.PublishInfoDo[]|{"Topic":.Topic,"Tags":.Tags}-Name:tagResources Action:ACS:ExecuteAPI Description:TagTopics Properties:Service:Ons API:TagResources ...
问题现象 Topic的分区更新时间显示为1970或者为“-”。可能原因 出现此问题的原因可能是以下情况中的一种：该分区没有消息数据，或者消息都已过期。客户端版本过低，或者传递的时间戳为null。Local存储引擎：开源Apache Kafka接口未提供该...
云消息队列 Kafka 版 不再支持按照Topic规格购买实例，存量的按照Topic规格购买的实例，也将转换为按照分区规格购买类型。无论您的已有实例是按照Topic规格购买还是按照分区规格购买，目前 升降配 只支持按照分区规格变更。同时，后台会对...
本文介绍如何使用 云消息队列 Kafka 版 提供的迁移工具将自建Kafka集群的Topic迁移到 云消息队列 Kafka 版 实例。前提条件 您已完成以下操作：下载JDK 8 下载迁移工具kafka-migration-assessment.jar 购买并部署 云消息队列 Kafka 版 实例...
云消息队列 RocketMQ 版 4.x系列实例提供的TCP服务于2023年11月30日后，不再支持经典网络ECS实例中的应用访问新建实例及Topic。因 云消息队列 RocketMQ 版 经典网络资源售罄，如果您的应用部署在经典网络ECS实例上，且访问的是 云消息队列 ...
ALIYUN:ROCKETMQ5:Topic类型用于ROCKETMQ5.0系列创建主题。语法 {"Type":"ALIYUN:ROCKETMQ5:Topic","Properties":{"InstanceId":String,"MessageType":String,"Remark":String,"TopicName":String } } 属性 属性名称 类型 必须 允许更新 ...
示例产品功能描述 示例产品连接到阿里云物联网平台之后，将会订阅TOPIC“/${ProductKey}/${deviceName}/user/get”的数据，然后每4秒发送一个消息到该topic，意味着这个消息会被发送到物联网平台，然后由于设备自己订阅了这个topic，因此...
代码中设置的Topic名称和已创建的Topic的名称不一致。SDK版本不匹配。针对有命名空间的实例，使用的SDK版本必须大于1.7.9.Final。若实例有命名空间，且错误信息后没有 {instancId}%{topic} 内容，说明使用的SDK版本不正确。解决方案 登录 ...
云存储和Local存储。云消息队列 Kafka 版 实例支持云存储和Local存储。详情请参见 存储引擎对比。
请求参数 名称 类型 必填 描述 示例值 TopicName string 是 需要删除的 topic 名称。tf-testAccMNSTopic-112965059402264645 返回参数 名称 类型 描述 示例值 object RequestId string 请求的 ID。06273500-249F-5863-121D-74D51123*Code ...
请求参数 名称 类型 必填 描述 示例值 TopicName string 是 需创建的 topic 的名称。test EnableLogging boolean 否 是否开启日志管理功能。取值说明如下：True：启用。False：停用。默认值：False。true MaxMessageSize long 否 发送到该...
操作 访问级别 资源类型 条件关键字 关联操作 rocketmq:DeleteTopic Write Topic acs:rocketmq:{#regionId}:{#accountId}:instance/{#InstanceId}/topic/{#TopicName} 无 无 请求语法 DELETE/instances/{instanceId}/topics/{topicName} ...
创建云消息队列 RocketMQ 版的主题（Topic）。主题是云消息队列 RocketMQ 版中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。在消息收发模型中，生产者将消息发送至主题，消费者通过订阅指定的主题来消费其中的消息。调试 您...
demo-topic","MessageCount":0,"MaxMessageSize":65536,"MessageRetentionPeriod":86400,"CreateTime":1449554962,"LastModifyTime":1449554962,"LoggingEnabled":true,"TopicUrl":"","TopicInnerUrl":"","Tags":[{"TagKey":"","TagValue...
Topic分区引流 如果某一云存储类型的Topic分区分配不均且流量过大，导致集群某个磁盘水位飙升，那么可以针对此Topic使用Topic分区引流功能，将此Topic分区上的流量引流至磁盘水位较低的节点。风险说明 为了保证集群稳定，进行集群分区均衡...
调用该接口查询向指定自定义Topic订阅消息的目标Topic，即指定Topic的路由表。QPS限制 单个阿里云账号调用该接口的每秒请求数（QPS）最大限制为50。说明 RAM用户共享阿里云账号配额。调试 您可以在OpenAPI Explorer中直接运行该接口，免去...
Description String 否 submit a test topic Topic的描述信息。长度限制为100字符（一个中文汉字占一个字符）。调用API时，除了本文介绍的该API的特有请求参数，还需传入公共请求参数。公共请求参数说明，请参见 公共参数文档。返回数据 ...
通过规则引擎的云产品流转功能，物联网平台可将指定Topic的数据流转至其他的Topic和阿里云产品中。本文将为您介绍设置数据流转规则的完整操作步骤，依次是创建规则、编写处理数据的SQL、设置数据流转目的地、设置流转失败的数据转发目的地...
XML 格式<QueryTopicReverseRouteTableResponse><SrcTopics><Topic>/CXi4*/device1/user/get</Topic><Topic>/CXi4*/device4/user/get</Topic></SrcTopics><RequestId>C5515170-3C1F-4004-A7C1-181E7955BC73</RequestId><Success>true...
物联网平台支持将设备相关的指定消息Topic通过云产品流转功能，流转至其他Topic、业务服务器或其他阿里云产品中进行处理、过滤、存储和分析等操作。云产品流转功能通过配置数据流转解析器关联数据源（设备消息）和数据目的，使用解析脚本...
设备影子数据通过Topic进行流转，主要包括设备上报状态到设备影子、应用程序更改设备状态、设备离线再上线后主动获取设备影子信息，和设备端请求删除设备影子中的属性信息。本文介绍设备影子Topic及其数据格式。设备影子Topic 物联网平台已...
本文介绍Python语言的自定义Topic消息解析脚本模板和示例。脚本模板 SELF_DEFINE_TOPIC_UPDATE_FLAG='/user/update'#自定义Topic：/user/update。SELF_DEFINE_TOPIC_ERROR_FLAG='/user/update/error'#自定义Topic：/user/update/error。将...
Topic可分为自定义Topic、基础通信Topic和物模型Topic，其中自定义Topic中的数据格式由您定义。本文介绍基础通信Topic和物模型通信Topic数据经过消息转发后的数据格式。消息转发与设备原始通信的Topic说明 通信Topic的定义、使用和分类说明...
在指定环境实例下创建一个 Topic，需要指定消息类型与 Topic 名称。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 ...
删除指定的 Topic。删除后，该 Topic 下所有的订阅关系会被清理，需谨慎调用。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选...
Online Boolean true 是否在线 SubscriptionDataList Array of SubscriptionDataList 订阅信息列表 SubString String*订阅匹配字符串 Online Boolean true 是否在线 Topic String test-mq_topic Topic 名称 示例 请求示例 http(s):/...