当您想要将A地域的 云消息队列 Kafka 版 上的业务无损迁移至B地域，或者创建实例后想复制已有实例元数据（Topic、Group）配置时，您可以使用 云消息队列 Kafka 版 提供的迁移工具将某个 云消息队列 Kafka 版 实例的Topic、Group迁移至另...
Topic减分区会造成数据丢失。这是Apache Kafka自身设计所限制的。
可使用的Topic数量与总分区数强相关。例如，您已购买了分区数为50、流量规格为alikafka.hw.2xlarge、规格内赠送分区数为1000的实例，那么该实例总分区数=购买分区数+规格内赠送分区数=50+1000=1050，可用Topic数量与总分区数量相等为1050。...
云消息队列 Kafka 版 不再支持按照Topic规格购买实例。若您的已有实例是按照Topic规格购买 Topic说明如下：不同的流量规格对应不同的Topic或分区数量上限。在默认分区数的基础上，每增购1个Topic，对应增加16个分区。例如，您购买了Topic...
本文介绍如何调用 EnableAutoTopicCreation 开启和关闭自动创建Topic，以及修改自动创建 Topic 默认分区数。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例...
修改Topic的备注。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action 元素中使用，...
自2022年8月26日起，消息队列Kafka版 不再支持按照Topic规格购买实例。若您的已有实例是2022年8月26日之前购买的，规格内包含的Topic数和分区数如下所示：表 1.标准版（高写版）流量规格内预包含Topic、Group数（公共云）流量规格 网卡读...
Topic总数（分区总数）太多会使集群性能和稳定性能急剧下降。云消息队列 Kafka 版 的存储和协调机制是以分区为粒度的，分区数太多，会导致存储碎片化严重，集群性能和稳定性都会急剧下降。
修改Topic的分区数。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action 元素中使用...
本文以智能灯和手机App连接为例，基于物联网平台的Topic消息路由服务，构建一个M2M设备间通信架构。背景信息 智能灯控制流程如下图：操作步骤 在 物联网平台控制台，为智能灯设备创建产品和设备，定义功能等。具体操作，请参见 创建产品、...
Group 没有消费过该Topic分区的消息。如果 Group 没有消费过某Topic分区的消息，那么 Group 对应的Topic分区的最近消费时间显示为1970。
'{{instanceId}}' Outputs:updateTopicAndTags:Type:List ValueSelector:.Data.PublishInfoDo[]|{"Topic":.Topic,"Tags":.Tags}-Name:tagResources Action:ACS:ExecuteAPI Description:TagTopics Properties:Service:Ons API:TagResources ...
api_1681624879908 示例 正常返回示例 JSON 格式 {"RequestId":"06084011-E093-46F3-A51F-4B19A8AD*","Code":200,"Success":true,"Message":"operation success","TopicSubscribeStatus":{"ConsumerGroups":["group_test"],"Topic":"topic_...
问题现象 发送消息到某个Topic后，该Topic下部分分区消息比较多，部分分区消息少，甚至没有。分区中消息量可以在 Topic详情 页面的 分区状态 页签查看，位点数即是消息数。以下图为例，分区 2 消息比较多，其他分区消息少甚至没有，消息...
问题现象 Topic的分区更新时间显示为1970或者为“-”。可能原因 出现此问题的原因可能是以下情况中的一种：该分区没有消息数据，或者消息都已过期。客户端版本过低，或者传递的时间戳为null。Local存储引擎：开源Apache Kafka接口未提供该...
获取Topic和分区的使用配额。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action ...
代码中设置的Topic名称和已创建的Topic的名称不一致。SDK版本不匹配。针对有命名空间的实例，使用的SDK版本必须大于1.7.9.Final。若实例有命名空间，且错误信息后没有 {instancId}%{topic} 内容，说明使用的SDK版本不正确。解决方案 登录 ...
demo-topic","MessageCount":0,"MaxMessageSize":65536,"MessageRetentionPeriod":86400,"CreateTime":1449554962,"LastModifyTime":1449554962,"LoggingEnabled":true,"TopicUrl":"","TopicInnerUrl":"","Tags":[{"TagKey":"","TagValue...
failed to get master store addr for topic aliyun_sz_ecs_rdsr*y-1-0 问题原因 订阅通道的消费时间点设置早于实际消费时间。解决方案 数据订阅的前提是SDK配置 usePublicIp=true 参数，确认不是这个问题后进行下一步排查。说明 数据订阅...
云消息队列 RocketMQ 版 4.x系列实例提供的TCP服务于2023年11月30日后，不再支持经典网络ECS实例中的应用访问新建实例及Topic。因 云消息队列 RocketMQ 版 经典网络资源售罄，如果您的应用部署在经典网络ECS实例上，且访问的是 云消息队列 ...
云存储和Local存储。云消息队列 Kafka 版 实例支持云存储和Local存储。详情请参见 存储引擎对比。
取消订阅Topic 取消订阅是订阅的逆过程，二者遵循同样的
Topic规则。仍然以取消订阅用户所绑定设备属性变化的Topic为例。import<AlinkAppExpress/LKAppExpress.h>/详细的使用说明请参考 api reference[[LKAppExpress sharedInstance]...
Direct Exchange根据Routing Key完全匹配的规则路由消息的示例如下：Message Routing Key 绑定关系中的Routing Key Queue Message A img.create img.create Queue A Message B img.log img.log Queue B Topic Exchange 路由规则 Topic ...
格式如下：请求Topic：{srcApp}/request/linkedge/{method} 应答Topic：linkedge/response/{srcApp}/{method} 事件通知Topic：linkedge/notify/{event-name} ibms应用程序获取分组中所有的设备列表Topic：请求Topic：ibms/request/linkedge...
调用该接口对指定Topic新建一个规则。使用说明 调用该接口时，请求参数 ProductKey必须传入。QPS限制 单个阿里云账号调用该接口的每秒请求数（QPS）最大限制为50。说明 单个阿里云账号下的所有RAM用户共享该阿里云账号的配额。调试 您可以...
ALIYUN:IOT:Rule类型用于为指定Topic新建一个规则。语法 {"Type":"ALIYUN:IOT:Rule","Properties":{"TopicType":Integer,"IotInstanceId":String,"ResourceGroupId":String,"ShortTopic":String,"Select":String,"DataType":String,...
调用该接口为规则引擎中数据源添加Topic。使用说明 调用该接口前，请先创建数据源，具体操作，请参见 创建数据源的步骤1~步骤6；然后在物联网平台控制台对应实例下 消息转发>云产品流转页面的 数据源页签，查看 数据源ID。重要 对于开源...
调用该接口在指定的规则下创建一个规则动作，定义将处理后的Topic数据，转发至物联网平台的其他Topic，或所支持的其他阿里云服务。使用说明 服务地域不同，所支持的目标云产品有所不同。规则引擎支持的地域及目标云产品，请参见 地域与可用...
规则描述如下所示。如果消息以BrandA开头，发送至BrandA-item-topic和BrandA-discount-topic这两个topic。如果消息以BrandB开头，发送至BrandB-item-topic和BrandB-discount-topic这两个topic。其余消息发送至Unknown-brand-topic。规则的...
规则描述如下所示。如果消息以BrandA开头，发送至BrandA-item-topic和BrandA-discount-topic这两个topic。如果消息以BrandB开头，发送至BrandB-item-topic和BrandB-discount-topic这两个topic。其余消息发送至Unknown-brand-topic。规则的...
规则描述如下所示。如果消息以BrandA开头，发送至BrandA-item-topic和BrandA-discount-topic这两个topic。如果消息以BrandB开头，发送至BrandB-item-topic和BrandB-discount-topic这两个topic。其余消息发送至Unknown-brand-topic。规则的...
单击 刷新源表和DataHub Topic映射 将根据您在步骤三配置的 表名到Topic的映射规则 来生成目标Topic，若步骤三未配置映射规则，将默认写入与源表同名的目标Topic，若目标端不存在该同名Topic，将默认新建。同时，您可以修改Topic建立方式、...
规则描述如下所示。如果消息以BrandA开头，发送至BrandA-item-topic和BrandA-discount-topic这两个topic。如果消息以BrandB开头，发送至BrandB-item-topic和BrandB-discount-topic这两个topic。其余消息发送至Unknown-brand-topic。规则的...