This data source provides a list of ONS Groups in an Alibaba Cloud account according to the specified filters.->NOTE:Available in 1.53.0+Example Usage variable"name"{ default="onsInstanceName"} variable"group_name"{ ...
ons_instance""default"{ instance_name=var.name remark="default_ons_instance_remark"} resource"alicloud_ons_topic""default"{ topic_name=var.topic instance_id=alicloud_ons_instance.default.id message_type=0 remark="dafault_...
Provides an ONS topic resource.For more information about how to use it,see RocketMQ Topic Management API.->NOTE:Available in 1.53.0+Example Usage Basic Usage variable"name"{ default="onsInstanceName"} variable"topic"{ ...
Using this data source can open ONS service automatically.If the service has been opened,it will return opened.For information about ONS and how to use it,see What is ONS.->NOTE:Available in v1.111.0+Example Usage data...
Provides an ONS group resource.For more information about how to use it,see RocketMQ Group Management API.->NOTE:Available in 1.53.0+Example Usage Basic Usage variable"name"{ default="GID-tf-example"} variable"group_name"{...
ons_instance""default"{ name="${var.name}"remark="default_ons_instance_remark"} data"alicloud_ons_instances""instances_ds"{ ids=["${alicloud_ons_instance.default.id}"]name_regex="${alicloud_ons_instance.default.name}...
Provides an ONS instance resource.For more information about how to use it,see RocketMQ Instance Management API.->NOTE:The number of instances in the same region cannot exceed 8.At present,the resource does not support ...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 RocketMQ 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。创建消息流出任务 登录 云...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务,实现将其他数据源中的数据快速导入 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。创建...
本文提供使用 消息队列RocketMQ版 的TCP Java SDK收发消息的快速入门视频。
云消息队列 RocketMQ 版 所提供的TCP Java SDK支持多线程消费,且适用于所有消息类型,本文介绍如何设置消费线程数的方法。在启动Consumer时,设置一个ConsumeThreadNums属性即可。具体示例如下所示。public static void main(String[]args...
客户端需要通过接入点接入云消息队列 RocketMQ 版完成消息的收发,可通过调用本接口查询实例接入点。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。调试 ...
本文介绍 云消息队列 RocketMQ 版 中消费者(Consumer)的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 消费者是 云消息队列 RocketMQ 版 中用来接收并处理消息的运行实体。消费者通常被集成在业务系统中,从 云消息...
本文介绍 云消息队列 RocketMQ 版 中消费者分组(ConsumerGroup)的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 消费者分组是 云消息队列 RocketMQ 版 系统中承载多个消费行为一致的消费者的负载均衡分组。和消费者...
调用OnsRegionList获取云消息队列 RocketMQ 版目前开放服务的地域(Region)信息列表。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API,用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成,消息收发的核心数据链路中严禁依赖...
实例是用于云消息队列 RocketMQ 版服务的虚拟机资源,用来存储 Topic 和 Group 信息。该接口一般在新业务发布需要创建新的服务资源的情况下使用。该接口只支持创建标准版实例,不支持创建铂金版实例。云消息队列 RocketMQ 版控制台同时支持...
调用OnsInstanceDelete接口删除云消息队列 RocketMQ 版实例。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API,用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成,消息收发的核心数据链路中严禁依赖 OpenAPI 实现,否则可能...
调用OnsTopicCreate接口创建Topic。...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsTopicCreate 接口,您还可以通过消息队列 RocketMQ 版控制台,创建 Topic。具体操作,请参见 Topic 管理。
本接口的实现基于云消息队列 RocketMQ 版的内部位点机制,在大部分场景下判断结果可信,但如果应用方进行过重置位点已经清除消息等操作,则判断结果可能有误。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行...
当前消息队列 RocketMQ 版不管理死信重发的状态,重发后消费成功的消息不会从死信队列中移除。需自行管理、判断消息是否需要重发。避免多次无意义地重发,从而造成重复消费。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算...
请求参数 名称 类型 必填 描述 示例值 InstanceId string 是 云消息队列 RocketMQ 版实例 ID。MQ_INST_184681981*_BXig0x6A Topic string 是 需查询的消息的 Topic 名称。test-mq_topic MsgId string 是 需查询的消息的 ID,即 Message ID...
调用OnsGroupCreate创建客户端Group ID。接口说明 注意 阿里云提供的 OpenAPI 属于管控类...错误码 400 变更 控制台操作 除了调用 OnsGroupCreate 接口,您还可以通过消息队列 RocketMQ 版控制台创建 Group ID。具体操作,请参见 Group 管理。
调用OnsGroupDelete删除Group。...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsGroupDelete 接口,您还可以通过云消息队列 RocketMQ 版控制台删除 Group ID。具体操作,请参见 Group 管理。
调用OnsTopicDelete接口删除指定的Topic。...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsTopicDelete 接口,您还可以通过云消息队列 RocketMQ 版控制台删除 Topic。具体操作,请参见 Topic 管理。
调用OnsInstanceUpdate接口更新实例名称和...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsInstanceUpdate 接口,您还可以通过云消息队列 RocketMQ 版控制台更新实例名称和描述。具体操作,请参见 实例管理。
查看有哪些在线订阅组订阅了...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsTopicSubDetail 接口,您还可以通过云消息队列 RocketMQ 版控制台查看 Topic 和 Group 的订阅关系。具体操作,请参见 查看订阅关系。
通过传入Topic名称和Message Key创建...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsTraceQueryByMsgKey 接口,您还可以通过云消息队列 RocketMQ 版控制台创建消息轨迹查询任务。具体操作,请参见 消息查询。
查看Group订阅了哪些Topic,...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsGroupSubDetail 接口,您还可以通过云消息队列 RocketMQ 版控制台查看 Topic 和 Group 的订阅关系。具体操作,请参见 查看订阅关系。
重置指定的Group ID的...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsConsumerResetOffset 接口,您还可以通过云消息队列 RocketMQ 版控制台重置指定 Group ID 的消费位点。具体操作,请参见 重置消费位点。
通过传入Topic名称和Message ID创建轨迹...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsTraceQueryByMsgId 接口,您还可以通过云消息队列 RocketMQ 版控制台创建消息轨迹查询任务。具体操作,请参见 消息查询。
查询一段时间内指定的...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsTrendTopicInputTps 接口,您还可以通过云消息队列 RocketMQ 版控制台查看指定 Topic 中生产消息的统计数据。具体操作,请参见 仪表盘。
变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsTrendGroupOutputTps 接口,您还可以通过云消息队列 RocketMQ 版控制台查看指定 Group ID 下的消费消息的统计数据。具体操作,请参见 仪表盘。
变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsConsumerGetConnection 接口,您还可以通过云消息队列 RocketMQ 版控制台查看指定 Group ID 下客户端的连接情况。具体操作,请参见 查看消费者状态。
查询指定Group ID详细状态数据:订阅关系检查、消费TPS统计、负载均衡状态、消费端...控制台操作 除了调用 OnsConsumerStatus 接口,您还可以通过云消息队列 RocketMQ 版控制台查看 Group ID 的详细数据。具体操作,请参见 查看消费者状态。
通过传入 Message ID 查询指定消息的信息...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsMessageGetByMsgId 接口,您还可以通过消息队列 RocketMQ 版控制台查看消息的详细信息。具体操作,请参见 消息查询。
根据 Topic 和 Message Key 模糊查询消息...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsMessageGetByKey 接口,您还可以通过云消息队列 RocketMQ 版控制台查看消息的详细信息。具体操作,请参见 消息查询。
变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsConsumerAccumulate 接口,您还可以通过云消息队列 RocketMQ 版控制台查看 Group ID 的消息消费堆积情况。具体操作,请参见 查看消费者状态。
通过传入Message ID查询指定的死信消息。...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsDLQMessageGetById 接口,您还可以通过云消息队列 RocketMQ 版控制台查看死信消息。具体操作,请参见 死信队列。