CreateConsumerGroup

请求参数 名称 类型 是否必选 示例值 描述 Action String 是 CreateConsumerGroup 系统规定参数。取值:CreateConsumerGroup。GroupName String 是 消费组1 消费组名称。支持中文汉字、英文字母、数字和下划线(_),长度为4~30个字符,...

CreateConsumerGroup

400 ConsumerGroupAlreadyExist consumer group already exist.消费组已存在。400 JsonInfoInvalid consumerGroup or timeout is of error format.参数consumerGroup或timeout格式错误。500 InternalServerError Specified Server Error ...

CreateConsumerGroup-创建消费组

调用CreateConsumerGroup创建Group。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息,可以在RAM权限策略语句的 ...

CreateConsumerGroup-创建消费者分组

操作 访问级别 资源类型 条件关键字 关联操作 rocketmq:CreateConsumerGroup Write ConsumerGroup acs:rocketmq:{#regionId}:{#accountId}:instance/{#InstanceId}/consumergroup/{#ConsumerGroupId} 无 无 请求语法 POST/instances/{...

create_consumer_group

请求语法 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-...

CreateConsumerGroupSubscribeRelation

调用 CreateConsumerGroup 创建消费组成功后,会返回消费组ID。您可以调用 QueryConsumerGroupList 按消费组名称查询消费组ID。ProductKey String 是 a1fyXVF*该订阅中的产品的 ProductKey。IotInstanceId String 否 iot-cn-0pp1n8t*实例ID...

创建消费组

调用CreateConsumerGroup接口为数据订阅实例新增消费组。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述 Action ...

自由使用Group

在迁移上云或测试场景下,您可以开启自由使用Group功能,通过代码写入直接创建Group,无需在控制台手动创建,帮助您简化操作,提升效率。前提条件 您已购买并部署 云消息队列 Kafka 版 实例,且该实例必须满足以下条件:项目 说明 状态 ...

API概览

GetConsumerList 获取Consumer Group信息 调用GetConsumerList获取Group信息。GetConsumerProgress 查询消费组消费状态 查询Consumer Group的消费状态。标签 API 标题 API概述 ListTagResources 查询资源绑定的标签列表 调用...

使用Terraform管理Kafka Consumer Group

本文介绍如何使用Terraform提供的 alicloud_alikafka_consumer_group 资源来创建和管理阿里云Kafka消费者组(Consumer Group)。前提条件 已购买和部署云消息队列 Kafka 版实例。安装Terraform。支持Terraform 0.13及以上版本。方式一:在...

使用Python SDK管理消费组

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 ...

使用Java SDK管理消费组

} } } 预期结果如下: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:...

云消息队列 Kafka 版支持被审计的事件说明

CreateAcl 创建ACL CreateConnectorTask 创建连接器任务 CreateConsumerGroup 创建Consumer Group CreatePostPayOrder 创建后付费实例 CreatePrePayOrder 创建预付费实例 CreateSaslUser 创建SASL用户 CreateTopic 创建Topic DeleteAcl ...

步骤三:创建资源

当使用 云消息队列 Kafka 版 进行消息收发时,您需要在已成功部署的Kafka实例中创建Topic和Group资源。生产者需要将消息发送至指定Topic,消费者通过订阅Topic获取消息进行消费。消费者消费消息时,需要指定Group订阅对应的Topic。Group和...

API概览

消费组(Consumer Group)API名称 API说明 CreateConsumerGroup 在指定的Logstore上创建一个消费组。DeleteConsumerGroup 删除指定的消费组。UpdateConsumerGroup 修改指定消费组的属性信息。GetCheckPoint 获取指定消费组消费数据时Shard...

AliyunAnalyticDBAccessingLogRolePolicy

log:PostLogStoreLogs","log:CreateConsumerGroup","log:UpdateConsumerGroup","log:DeleteConsumerGroup","log:ListConsumerGroup","log:ConsumerGroupUpdateCheckPoint","log:ConsumerGroupHeartBeat","log:GetConsumerGroupCheckPoint...

消息队列RocketMQ 5.0的审计事件

事件名称 事件含义 Create 登录产品售卖页的购买操作。Renew 实例或资源包等的续费操作。Release 资源到期自动释放。Modify 登录产品售卖页面进行的变配操作。ChangeResourceGroup 修改资源组。CreateTopic 创建主题。CreateInstance 创建...

API概览

管理消费组: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 ...

ResetConsumerGroupPosition

调用 CreateConsumerGroup 创建消费组成功后,会返回消费组ID。您可以调用 QueryConsumerGroupList 按消费组名称查询消费组ID。IotInstanceId String 否 iot-cn-0pp1n8t*实例ID。您可在物联网平台控制台的 实例概览页面,查看当前实例的 ID...

UpdateConsumerGroup

调用 CreateConsumerGroup 创建消费组成功后,会返回消费组ID。您可以调用 QueryConsumerGroupList 按消费组名称查询消费组ID。NewGroupName String 是 消费组2 消费组的新名称。支持中文汉字、英文字母、数字和下划线(_),长度为4~30个...

CreateSubscribeRelation

调用 CreateConsumerGroup 创建消费组,返回消费组ID。AMQP订阅中,消息将被推送到指定消费组,AMQP客户端携带消费组ID接入物联网平台,消费消息,请参见 AMQP客户端接入说明。2.调用本接口创建AMQP订阅。3.(可选)调用 ...

DeleteConsumerGroup

调用 CreateConsumerGroup 创建消费组成功后,会返回消费组ID。您可以调用 QueryConsumerGroupList 按消费组名称查询消费组ID。IotInstanceId String 否 iot-cn-0pp1n8t*实例ID。您可在物联网平台控制台的 实例概览页面,查看当前实例的 ID...

消息队列Kafka版的审计事件

Create 登录产品售卖页面进行的购买操作。CreateAcl 创建ACL。CreateConnectorTask 创建连接器任务。CreateConsumerGroup 创建消费组。CreatePostPayOrder 创建后付费实例。CreatePrePayOrder 创建预付费实例。CreateSaslUser 创建SASL用户...

API概览

消费者分组 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自定义授权场景。...

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...

QueryConsumerGroupByGroupId

调用 CreateConsumerGroup 创建消费组成功后,会返回消费组ID。您可以调用 QueryConsumerGroupList 按消费组名称查询消费组ID。IotInstanceId String 否 iot-cn-0pp1n8t*实例ID。您可在物联网平台控制台的 实例概览页面,查看当前实例的 ID...

OpenSearch服务关联角色

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:...

日志服务SLS的审计事件

Create 登录产品售卖页面进行的购买操作。CreateChart 创建统计图表。CreateConfig 在Project下创建日志的Logtail配置。CreateConsumerGroup 在指定的Logstore上创建一个消费组。CreateDashboard 创建仪表盘。CreateDomain 创建域名。...

【通知】DTS旧版OpenAPI即将停止维护

自2022年1月1日起,DTS...暂无 DescribeSynchronizationObjectModifyStatus 管理订阅任务的消费组 CreateConsumerChannel DescribeConsumerChannel ModifyConsumerChannel DeleteConsumerChannel CreateConsumerGroup DescribeConsumerGroup ...

Flink消费

示例如下:configProps.put(ConfigConstants.LOG_CONSUMERGROUP,"your consumer group name");说明 该项为可选配置项,设置后Flink Log Consumer会首先创建消费组,如果消费组已经存在,则不执行任何操作,Flink Log Consumer中的snapshot...

管理AMQP消费组

消费组是消息消费端的身份标识,多个消费者组成消息消费组接入物联网平台。设置AMQP服务端订阅后,物联网平台会将收到的设备消息转发到相应消费组,每条被流转到消费组的消息会被其中一个消费者接收。本文介绍如何在物联网平台创建、查看和...

配置数据源(RDS/PolarDB)报错

dts:CreateConsumerGroup","dts:StartSubscriptionInstance","dts:DescribeSubscriptionInstanceStatus","dts:DescribeConsumerGroup","dts:DeleteConsumerGroup"],"Resource":"*","Effect":"Allow"},{"Action":"ram:...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
弹性公网IP 短信服务 人工智能平台 PAI 物联网平台 对象存储 金融分布式架构
新人特惠 爆款特惠 最新活动 免费试用