请求参数 名称 类型 是否必选 示例值 描述 Action String 是 CreateConsumerGroup 系统规定参数。取值:CreateConsumerGroup。GroupName String 是 消费组1 消费组名称。支持中文汉字、英文字母、数字和下划线(_),长度为4~30个字符,...
400 ConsumerGroupAlreadyExist consumer group already exist.消费组已存在。400 JsonInfoInvalid consumerGroup or timeout is of error format.参数consumerGroup或timeout格式错误。500 InternalServerError Specified Server Error ...
调用CreateConsumerGroup创建Group。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息,可以在RAM权限策略语句的 ...
操作 访问级别 资源类型 条件关键字 关联操作 rocketmq:CreateConsumerGroup Write ConsumerGroup acs:rocketmq:{#regionId}:{#accountId}:instance/{#InstanceId}/consumergroup/{#ConsumerGroupId} 无 无 请求语法 POST/instances/{...
请求语法 aliyunlog log create_consumer_group-project=<value>-logstore=<value>-consumer_group=<value>-timeout=[-in_order=][-access-id=][-access-key=][-sts-token=][-region-endpoint=][-client-name=][-jmes-filter=][-format-...
调用 CreateConsumerGroup 创建消费组成功后,会返回消费组ID。您可以调用 QueryConsumerGroupList 按消费组名称查询消费组ID。ProductKey String 是 a1fyXVF*该订阅中的产品的 ProductKey。IotInstanceId String 否 iot-cn-0pp1n8t*实例ID...
调用CreateConsumerGroup接口为数据订阅实例新增消费组。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述 Action ...
在迁移上云或测试场景下,您可以开启自由使用Group功能,通过代码写入直接创建Group,无需在控制台手动创建,帮助您简化操作,提升效率。前提条件 您已购买并部署 云消息队列 Kafka 版 实例,且该实例必须满足以下条件:项目 说明 状态 ...
GetConsumerList 获取Consumer Group信息 调用GetConsumerList获取Group信息。GetConsumerProgress 查询消费组消费状态 查询Consumer Group的消费状态。标签 API 标题 API概述 ListTagResources 查询资源绑定的标签列表 调用...
本文介绍如何使用Terraform提供的 alicloud_alikafka_consumer_group 资源来创建和管理阿里云Kafka消费者组(Consumer Group)。前提条件 已购买和部署云消息队列 Kafka 版实例。安装Terraform。支持Terraform 0.13及以上版本。方式一:在...
consumergroup_name="ali-test-consumergroup"if_name_='_main_':print("ready to create consumergroup")res=client.create_consumer_group(project_name,logstore_name,consumergroup_name,300,in_order=False)print("create ...
} } } 预期结果如下:ready to update checkpoint ConsumerName is:consumerGroupX Consumer order is:false ConsumerName is:ali-test-consumergroup2 Consumer order is:true ConsumerName is:ali-test-consumergroup Consumer order is:...
CreateAcl 创建ACL CreateConnectorTask 创建连接器任务 CreateConsumerGroup 创建Consumer Group CreatePostPayOrder 创建后付费实例 CreatePrePayOrder 创建预付费实例 CreateSaslUser 创建SASL用户 CreateTopic 创建Topic DeleteAcl ...
当使用 云消息队列 Kafka 版 进行消息收发时,您需要在已成功部署的Kafka实例中创建Topic和Group资源。生产者需要将消息发送至指定Topic,消费者通过订阅Topic获取消息进行消费。消费者消费消息时,需要指定Group订阅对应的Topic。Group和...
消费组(Consumer Group)API名称 API说明 CreateConsumerGroup 在指定的Logstore上创建一个消费组。DeleteConsumerGroup 删除指定的消费组。UpdateConsumerGroup 修改指定消费组的属性信息。GetCheckPoint 获取指定消费组消费数据时Shard...
log:PostLogStoreLogs","log:CreateConsumerGroup","log:UpdateConsumerGroup","log:DeleteConsumerGroup","log:ListConsumerGroup","log:ConsumerGroupUpdateCheckPoint","log:ConsumerGroupHeartBeat","log:GetConsumerGroupCheckPoint...
事件名称 事件含义 Create 登录产品售卖页的购买操作。Renew 实例或资源包等的续费操作。Release 资源到期自动释放。Modify 登录产品售卖页面进行的变配操作。ChangeResourceGroup 修改资源组。CreateTopic 创建主题。CreateInstance 创建...
管理消费组:CreateConsumerGroup DescribeConsumerGroup ModifyConsumerGroupPassword DeleteConsumerGroup ModifyConsumptionTimestamp 管理消费组:创建消费组。查询消费组详情。修改消费组密码。删除消费组。修改消费时间点。...
log:CreateConsumerGroup"],"Resource":["acs:log:*:*:project/log-project-dev-*/logstore/app_*_log","acs:log:*:*:project/log-project-dev-*/logstore/app_*_log/*"],"Effect":"Allow"}]} 更多授权场景,请参见 RAM自定义授权场景。...
在 Consumer Group状态 页面,查看每个Shard消费数据的进度。SDK方式 此处以Java SDK为例。运行ConsumerGroupTest.java,查看每个Shard消费数据的进度。import java.util.List;import com.aliyun.openservices.log.Client;import ...
API 访问级别 资源类型 条件关键字 关联操作 rocketmq:ChangeResourceGroup ChangeResourceGroup Write Instance acs:rocketmq:{#regionId}:{#accountId}:instance/{#InstanceId} 无 无 rocketmq:CreateConsumerGroup CreateConsumerGroup ...
在 Consumer Group状态 页面,查看每个Shard消费数据的进度。SDK方式 此处以Java SDK为例。运行ConsumerGroupTest.java,查看每个Shard消费数据的进度。import java.util.List;import com.aliyun.openservices.log.Client;import ...
调用 CreateConsumerGroup 创建消费组成功后,会返回消费组ID。您可以调用 QueryConsumerGroupList 按消费组名称查询消费组ID。IotInstanceId String 否 iot-cn-0pp1n8t*实例ID。您可在物联网平台控制台的 实例概览页面,查看当前实例的 ID...
调用 CreateConsumerGroup 创建消费组成功后,会返回消费组ID。您可以调用 QueryConsumerGroupList 按消费组名称查询消费组ID。NewGroupName String 是 消费组2 消费组的新名称。支持中文汉字、英文字母、数字和下划线(_),长度为4~30个...
调用 CreateConsumerGroup 创建消费组,返回消费组ID。AMQP订阅中,消息将被推送到指定消费组,AMQP客户端携带消费组ID接入物联网平台,消费消息,请参见 AMQP客户端接入说明。2.调用本接口创建AMQP订阅。3.(可选)调用 ...
调用 CreateConsumerGroup 创建消费组成功后,会返回消费组ID。您可以调用 QueryConsumerGroupList 按消费组名称查询消费组ID。IotInstanceId String 否 iot-cn-0pp1n8t*实例ID。您可在物联网平台控制台的 实例概览页面,查看当前实例的 ID...
Create 登录产品售卖页面进行的购买操作。CreateAcl 创建ACL。CreateConnectorTask 创建连接器任务。CreateConsumerGroup 创建消费组。CreatePostPayOrder 创建后付费实例。CreatePrePayOrder 创建预付费实例。CreateSaslUser 创建SASL用户...
消费者分组 API 标题 API概述 CreateConsumerGroup 创建消费者分组 创建云消息队列 RocketMQ 版的消费者分组(ConsumerGroup)。消费者分组是云消息队列 RocketMQ 版系统中承载多个消费行为一致的消费者的负载均衡分组。消费者需要通过指定...
log:CreateConsumerGroup"],"Resource":["acs:log:*:*:project/log-project-dev-*/logstore/app_*_log","acs:log:*:*:project/log-project-dev-*/logstore/app_*_log/*"],"Effect":"Allow"}]} 更多授权场景,请参见 RAM自定义授权场景。...
acs:log:*:*:project/<指定的Project名称>/dashboard/*"],"Effect":"Allow"},{"Action":["log:Get*","log:List*","log:Create*"],"Resource":["acs:log:*:*:project/<指定的Project名称>/savedsearch","acs:log:*:*:project/<指定的...
ConsumerGroup log:CreateConsumerGroup 在指定的Logstore上创建一个消费组。log:UpdateConsumerGroup 修改指定消费组属性。log:DeleteConsumerGroup 删除一个指定的消费组。log:ListConsumerGroup 查询指定Logstore的所有消费组。log:...
log:GetConsumerGroupCheckPoint","log:ConsumerGroupHeartBeat","log:ConsumerGroupUpdateCheckPoint","log:ListConsumerGroup","log:CreateConsumerGroup","log:UpdateConsumerGroup","log:PostLogStoreLogs","log:DeleteConsumerGroup...
调用 CreateConsumerGroup 创建消费组成功后,会返回消费组ID。您可以调用 QueryConsumerGroupList 按消费组名称查询消费组ID。IotInstanceId String 否 iot-cn-0pp1n8t*实例ID。您可在物联网平台控制台的 实例概览页面,查看当前实例的 ID...
drds:ModifyDrdsIpWhiteList","drds:DescribeDrdsDBIpWhiteList","drds:DescribeRdsList","drds:DescribeDrdsDB"],"Resource":"*","Effect":"Allow"},{"Action":["dts:ConfigureSubscriptionInstance","dts:CreateConsumerGroup",...
log:CreateConsumerGroup","log:UpdateConsumerGroup","log:PostLogStoreLogs","log:DeleteConsumerGroup"],"Resource":["acs:log:*:*:project/*/logstore/ipa-*","acs:log:*:*:project/*/logstore/ipa-*/*"]},{"Action":"ram:...
Create 登录产品售卖页面进行的购买操作。CreateChart 创建统计图表。CreateConfig 在Project下创建日志的Logtail配置。CreateConsumerGroup 在指定的Logstore上创建一个消费组。CreateDashboard 创建仪表盘。CreateDomain 创建域名。...
自2022年1月1日起,DTS...暂无 DescribeSynchronizationObjectModifyStatus 管理订阅任务的消费组 CreateConsumerChannel DescribeConsumerChannel ModifyConsumerChannel DeleteConsumerChannel CreateConsumerGroup DescribeConsumerGroup ...
示例如下:configProps.put(ConfigConstants.LOG_CONSUMERGROUP,"your consumer group name");说明 该项为可选配置项,设置后Flink Log Consumer会首先创建消费组,如果消费组已经存在,则不执行任何操作,Flink Log Consumer中的snapshot...
消费组是消息消费端的身份标识,多个消费者组成消息消费组接入物联网平台。设置AMQP服务端订阅后,物联网平台会将收到的设备消息转发到相应消费组,每条被流转到消费组的消息会被其中一个消费者接收。本文介绍如何在物联网平台创建、查看和...
dts:CreateConsumerGroup","dts:StartSubscriptionInstance","dts:DescribeSubscriptionInstanceStatus","dts:DescribeConsumerGroup","dts:DeleteConsumerGroup"],"Resource":"*","Effect":"Allow"},{"Action":"ram:...