GetQuotaTip-获取Topic和分区的使用配额
获取Topic和分区的使用配额。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action ...
基于Topic消息路由的M2M设备间通信
本文以智能灯和手机App连接为例，基于物联网平台的Topic消息路由服务，构建一个M2M设备间通信架构。背景信息 智能灯控制流程如下图：操作步骤 在 物联网平台控制台，为智能灯设备创建产品和设备，定义功能等。具体操作，请参见 创建产品、...
为什么限制Topic总数（分区总数）？
Topic总数（分区总数）太多会使集群性能和稳定性能急剧下降。云消息队列 Kafka 版 的存储和协调机制是以分区为粒度的，分区数太多，会导致存储碎片化严重，集群性能和稳定性都会急剧下降。
按照Topic规格购买的实例，流量规格内Topic和分区的预...
自2022年8月26日起，消息队列Kafka版 不再支持按照Topic规格购买实例。若您的已有实例是2022年8月26日之前购买的，规格内包含的Topic数和分区数如下所示：表 1.标准版（高写版）流量规格内预包含Topic、Group数（公共云）流量规格 网卡读...
为什么发送给Topic的消息在分区中分布不均衡
问题现象 发送消息到某个Topic后，该Topic下部分分区消息比较多，部分分区消息少，甚至没有。分区中消息量可以在 Topic详情 页面的 分区状态 页签查看，位点数即是消息数。以下图为例，分区 2 消息比较多，其他分区消息少甚至没有，消息...
为什么有Group对应的Topic分区显示1970？
Group 没有消费过该Topic分区的消息。如果 Group 没有消费过某Topic分区的消息，那么 Group 对应的Topic分区的最近消费时间显示为1970。
使用数据订阅SDK消费数据时报“... topic”错误
failed to get master store addr for topic aliyun_sz_ecs_rdsr*y-1-0 问题原因 订阅通道的消费时间点设置早于实际消费时间。解决方案 数据订阅的前提是SDK配置 usePublicIp=true 参数，确认不是这个问题后进行下一步排查。说明 数据订阅...
使用OOS将RocketMQ实例标签继承到Topic和Group
'{{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或“-”？
问题现象 Topic的分区更新时间显示为1970或者为“-”。可能原因 出现此问题的原因可能是以下情况中的一种：该分区没有消息数据，或者消息都已过期。客户端版本过低，或者传递的时间戳为null。Local存储引擎：开源Apache Kafka接口未提供该...
按照Topic规格购买的实例，如何转换为按照分区规格...
云消息队列 Kafka 版 不再支持按照Topic规格购买实例，存量的按照Topic规格购买的实例，也将转换为按照分区规格购买类型。无论您的已有实例是按照Topic规格购买还是按照分区规格购买，目前 升降配 只支持按照分区规格变更。同时，后台会对...
迁移Topic上云
本文介绍如何使用 云消息队列 Kafka 版 提供的迁移工具将自建Kafka集群的Topic迁移到 云消息队列 Kafka 版 实例。前提条件 您已完成以下操作：下载JDK 8 下载迁移工具kafka-migration-assessment.jar 购买并部署 云消息队列 Kafka 版 实例...
关于4.x系列实例的TCP服务不再支持...、Topic的公告
云消息队列 RocketMQ 版 4.x系列实例提供的TCP服务于2023年11月30日后，不再支持经典网络ECS实例中的应用访问新建实例及Topic。因 云消息队列 RocketMQ 版 经典网络资源售罄，如果您的应用部署在经典网络ECS实例上，且访问的是 云消息队列 ...
ALIYUN:ROCKETMQ5:Topic
ALIYUN:ROCKETMQ5:Topic类型用于ROCKETMQ5.0系列创建主题。语法 {"Type":"ALIYUN:ROCKETMQ5:Topic","Properties":{"InstanceId":String,"MessageType":String,"Remark":String,"TopicName":String } } 属性 属性名称 类型 必须 允许更新 ...
使用MQTT Topic与物联网平台通信
示例产品功能描述 示例产品连接到阿里云物联网平台之后，将会订阅TOPIC“/${ProductKey}/${deviceName}/user/get”的数据，然后每4秒发送一个消息到该topic，意味着这个消息会被发送到物联网平台，然后由于设备自己订阅了这个topic，因此...
通过Kafka命令行修改Topic/Broker属性
修改消息引擎Topic和Broker的配置参数对于系统性能优化和维护至关重要，本文档将介绍如何使用Kafka命令行工具访问和修改消息引擎配置，以帮助您及时了解和优化其配置，满足您的业务需求。前提条件 已安装Java环境，要求安装JDK 1.8及以上...
No route info of this topic”错误
代码中设置的Topic名称和已创建的Topic的名称不一致。SDK版本不匹配。针对有命名空间的实例，使用的SDK版本必须大于1.7.9.Final。若实例有命名空间，且错误信息后没有 {instancId}%{topic} 内容，说明使用的SDK版本不正确。解决方案 登录 ...
Topic的存储有哪些类型？
云存储和Local存储。云消息队列 Kafka 版 实例支持云存储和Local存储。详情请参见 存储引擎对比。
CreateTopic
说明 如果您使用Terraform管理 alicloud_message_service_topic，请将API中的参数 LoggingEnabled 替换为 EnableLogging。返回消息 返回消息由返回状态行，HTTP头和消息体三部分组成：HTTP Status Code HTTP/1.1 201 Created 同一个用户在...
ListTopic
Topic><TopicURL>http://$AccountId.mns.cn-hangzhou.aliyuncs.com/topics/$TopicName1</TopicURL></Topic><Topic><TopicURL>http://$AccountId.mns.cn-hangzhou.aliyuncs.com/topics/$...
DeleteTopic-删除主题
操作 访问级别 资源类型 条件关键字 关联操作 rocketmq:DeleteTopic Write Topic acs:rocketmq:{#regionId}:{#accountId}:instance/{#InstanceId}/topic/{#TopicName} 无 无 请求语法 DELETE/instances/{instanceId}/topics/{topicName} ...
CreateTopic-创建主题
创建云消息队列 RocketMQ 版的主题（Topic）。主题是云消息队列 RocketMQ 版中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。在消息收发模型中，生产者将消息发送至主题，消费者通过订阅指定的主题来消费其中的消息。调试 您...
分区均衡引流
Topic分区引流 如果某一云存储类型的Topic分区分配不均且流量过大，导致集群某个磁盘水位飙升，那么可以针对此Topic使用Topic分区引流功能，将此Topic分区上的流量引流至磁盘水位较低的节点。风险说明 为了保证集群稳定，进行集群分区均衡...
QueryTopicRouteTable
调用该接口查询向指定自定义Topic订阅消息的目标Topic，即指定Topic的路由表。QPS限制 单个阿里云账号调用该接口的每秒请求数（QPS）最大限制为50。说明 RAM用户共享阿里云账号配额。调试 您可以在OpenAPI Explorer中直接运行该接口，免去...
UpdateTopicConfig
Description String 否 submit a test topic Topic的描述信息。长度限制为100字符（一个中文汉字占一个字符）。调用API时，除了本文介绍的该API的特有请求参数，还需传入公共请求参数。公共请求参数说明，请参见 公共参数文档。返回数据 ...
设置数据流转规则
通过规则引擎的云产品流转功能，物联网平台可将指定Topic的数据流转至其他的Topic和阿里云产品中。本文将为您介绍设置数据流转规则的完整操作步骤，依次是创建规则、编写处理数据的SQL、设置数据流转目的地、设置流转失败的数据转发目的地...
QueryTopicReverseRouteTable
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...
DeleteTopic
调用DeleteTopic接口删除主题。注意 使用者必须谨慎使用此接口，主题被删除后，主题内所有消息和订阅该主题的Subscription也一并被删除，且不可恢复。...本接口的授权信息如下表所示。更多信息，请参见 授权策略和示例。...Request Body 无。...
添加待流转的数据源
物联网平台支持将设备相关的指定消息Topic通过云产品流转功能，流转至其他Topic、业务服务器或其他阿里云产品中进行处理、过滤、存储和分析等操作。云产品流转功能通过配置数据流转解析器关联数据源（设备消息）和数据目的，使用解析脚本...
设备影子数据流
设备影子数据通过Topic进行流转，主要包括设备上报状态到设备影子、应用程序更改设备状态、设备离线再上线后主动获取设备影子信息，和设备端请求删除设备影子中的属性信息。本文介绍设备影子Topic及其数据格式。设备影子Topic 物联网平台已...
Python脚本示例
本文介绍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的定义、使用和分类说明...
CreateMqSofamqTopic
在指定环境实例下创建一个 Topic，需要指定消息类型与 Topic 名称。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 ...
DeleteMqSofamqTopic
删除指定的 Topic。删除后，该 Topic 下所有的订阅关系会被清理，需谨慎调用。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选...
- 产品推荐
- 这些文档可能帮助您