消费组是消息消费端的身份标识,多个消费者组成消息消费组接入物联网平台。设置AMQP服务端订阅后,物联网平台会将收到的设备消息转发到相应消费组,每条被流转到消费组的消息会被其中一个消费者接收。本文介绍如何在物联网平台创建、查看和...
dts:CreateConsumerGroup","dts:StartSubscriptionInstance","dts:DescribeSubscriptionInstanceStatus","dts:DescribeConsumerGroup","dts:DeleteConsumerGroup"],"Resource":"*","Effect":"Allow"},{"Action":"ram:...
消费组 API 标题 API概述 CreateConsumerGroup 创建消费组 调用CreateConsumerGroup接口在指定的Logstore上创建一个消费组。DeleteConsumerGroup 删除消费组 删除一个指定的消费组 ConsumerGroupUpdateCheckPoint 更新消费进度 更新消费...
dts:CreateConsumerGroup","dts:StartSubscriptionInstance","dts:DescribeSubscriptionInstanceStatus","dts:DescribeConsumerGroup","dts:DeleteConsumerGroup"],"Resource":"*","Effect":"Allow"},{"Action":"ram:...
log:RetryShipperTask","log:CreateConsumerGroup","log:UpdateConsumerGroup","log:DeleteConsumerGroup","log:ListConsumerGroup","log:ConsumerGroupUpdateCheckPoint","log:ConsumerGroupHeartBeat","log:GetConsumerGroupCheckPoint...
log:CreateConsumerGroup","log:DeleteConsumerGroup"],"Resource":["acs:log:*:*:project/<指定的project名称>/logstore/<指定的Logstore名称>","acs:log:*:*:project/<指定的project名称>/logstore/<指定的Logstore名称>/*"],"Effect":...
log:ListMachines","log:ApplyConfigToGroup","log:RemoveConfigFromGroup","log:GetAppliedMachineGroups","log:GetAppliedConfigs","log:GetShipperStatus","log:RetryShipperTask","log:CreateConsumerGroup","log:UpdateConsumerGroup...
drds:ModifyDrdsIpWhiteList","drds:DescribeDrdsDBIpWhiteList","drds:DescribeRdsList","drds:DescribeDrdsDB"],"Resource":"*","Effect":"Allow"},{"Action":["dts:ConfigureSubscriptionInstance","dts:CreateConsumerGroup",...
调用 CreateConsumerGroup 创建消费组成功后,会返回消费组ID。您可以调用 QueryConsumerGroupList 按消费组名称查询消费组ID,也可以在物联网平台控制台对应实例下,选择 消息转发>服务端订阅>消费组列表,查看消费组ID。IotInstanceId ...
Create 登录产品售卖页面进行的购买操作。CreateAnalysisRecord 生成一键诊断报告。CreateAnalysisReportFeedback 创建一键诊断结果反馈。CreateConsumerChannel 创建订阅任务消费组。CreateConsumerGroup 创建消费组。...
命令:index="_internal"|search"error"异常日志:aliyun.log.consumer.exceptions.ClientWorkerException:error occour when create consumer group,errorCode:LogStoreNotExist,errorMessage:logstore xxxx does not exist ...
log:ConsumerGroupUpdateCheckPoint","log:ListConsumerGroup","log:CreateConsumerGroup","log:GetSlsService"],"Resource":"*","Effect":"Allow"},{"Action":["oss:ListBuckets","oss:GetBucketAcl","oss:GetBucketLogging","oss:...
调用 CreateConsumerGroup 创建消费组成功后,会返回消费组ID。您可以调用 QueryConsumerGroupList 按消费组名称查询消费组ID,也可以在物联网平台控制台 对应实例下,选择 消息转发>服务端订阅>消费组列表,查看消费组ID。SubscribeFlags ...
无 alikafka:CreateGroup CreateConsumerGroup Write 全部资源*无 无 alikafka:CreatePostPayOrder CreatePostPayOrder Write Instance acs:alikafka:{#regionId}:{#accountId}:instance/*alikafka:DeployModule alikafka:SpecType 无 ...
log:ApplyConfigToGroup","log:RemoveConfigFromGroup","log:GetAppliedMachineGroups","log:GetAppliedConfigs","log:GetShipperStatus","log:RetryShipperTask","log:CreateConsumerGroup","log:UpdateConsumerGroup","log:...
log:ApplyConfigToGroup","log:RemoveConfigFromGroup","log:GetAppliedMachineGroups","log:GetAppliedConfigs","log:GetShipperStatus","log:RetryShipperTask","log:CreateConsumerGroup","log:UpdateConsumerGroup","log:...
无 log:CreateConfig CreateConfig Write Project acs:log:{#regionId}:{#accountId}:project/{#ProjectName}/logtailconfig/{#LogtailConfigName} log:TLSVersion 无 log:CreateConsumerGroup CreateConsumerGroup Write LogStore acs:...
RetryShipperTask","log:CreateConsumerGroup","log:UpdateConsumerGroup","log:DeleteConsumerGroup","log:ListConsumerGroup","log:UpdateCheckPoint","log:HeartBeat","log:GetCheckPoint","log:CreateIndex","log:DeleteIndex","log:...
RetryShipperTask","log:CreateConsumerGroup","log:UpdateConsumerGroup","log:DeleteConsumerGroup","log:ListConsumerGroup","log:UpdateCheckPoint","log:HeartBeat","log:GetCheckPoint","log:CreateIndex","log:DeleteIndex","log:...
log:CreateConsumerGroup"],"Resource":["acs:log:*:*:project/log-project-prod/logstore/access_log","acs:log:*:*:project/log-project-prod/logstore/access_log/*"],"Effect":"Allow"}]} 为RAM用户S授予源Logstore读权限。...
log:CreateConsumerGroup","log:ListConsumerGroup","log:ConsumerGroupUpdateCheckPoint","log:ConsumerGroupHeartBeat","log:GetConsumerGroupCheckPoint","log:UpdateConsumerGroup"],"Resource":"*","Effect":"Allow"}]} 以上两类资源...
说明 当该订阅实例为新版,且调用 CreateConsumerGroup 接口创建了消费组时,才会返回本参数。SubscriptionDataType Struct 订阅数据的类型。DDL Boolean true 订阅数据是否包含DDL语句,返回值:true:是。false:否。DML Boolean true ...
log:CreateConsumerGroup"],"Resource":["acs:log:*:*:project/log-project-prod/logstore/access_log","acs:log:*:*:project/log-project-prod/logstore/access_log/*"],"Effect":"Allow"}]} 为RAM用户S授予源Logstore读权限。...
log:GetShipperStatus","log:GetCheckPoint","log:HeartBeat","log:UpdateCheckPoint","log:PostLogStoreLogs","log:CreateConsumerGroup","log:UpdateConsumerGroup","log:DeleteConsumerGroup","log:ListConsumerGroup","log:...
log:CreateConsumerGroup"],"Resource":["acs:log:*:*:project/log-project-prod/logstore/access_log","acs:log:*:*:project/log-project-prod/logstore/access_log/*"],"Effect":"Allow"}]} 为角色A授予源Logstore读权限。具体操作,请...
UpdateCheckPoint","log:PostLogStoreLogs","log:CreateConsumerGroup","log:UpdateConsumerGroup","log:DeleteConsumerGroup","log:ListConsumerGroup","log:ConsumerGroupUpdateCheckPoint","log:ConsumerGroupHeartBeat","log:...
如果RAM提供的系统策略无法满足您的业务需求,您可以通过创建自定义策略实现精细化权限管理(例如实例或操作级别的授权)。...详情请参见 授予DTS访问云资源的权限。背景信息 权限策略是用语法结构描述的一组权限的集合,可以精确地描述被授权...
{"Version":"1","Statement":[{"Action":["log:Get*","log:List*","log:CreateConsumerGroup","log:UpdateConsumerGroup","log:DeleteConsumerGroup","log:ListConsumerGroup","log:ConsumerGroupUpdateCheckPoint","log:...
log:CreateConsumerGroup"],"Resource":["acs:log:*:*:project/log-project-prod/logstore/access_log","acs:log:*:*:project/log-project-prod/logstore/access_log/*"],"Effect":"Allow"}]} 为角色A授予源Logstore读权限。具体操作,请...
说明 当该订阅实例为新版,且调用 CreateConsumerGroup 接口创建了消费组时,才会返回本参数。SubscriptionDataType Struct 订阅数据的类型。DDL Boolean true 订阅数据是否包含DDL语句,返回值:true:是。false:否。DML Boolean true ...
Provides a RocketMQ Consumer Group resource.For information about RocketMQ Consumer Group and how to use it,see What is Consumer Group.->NOTE:Available since v1.212.0.Example Usage Basic Usage variable"name"{ default=...
Provides an ALIKAFKA consumer group resource,see What is alikafka consumer group.->NOTE:Available since v1.56.0.->NOTE:Only the following regions support create alikafka consumer group.[cn-hangzhou ,cn-beijing ,...
问题原因 没有创建Consumer Group时会遇到此报错信息。解决方案 您可以选择如下任意一种方式创建Consumer Group。在云消息队列 Kafka 版的控制台创建Consumer Group。具体步骤请参见 创建Consumer Group。调用管控API创建Consumer Group。
消费组管理 create_consumer_group 在指定的Logstore上创建一个消费组。delete_consumer_group 删除一个指定的消费组。update_consumer_group 修改指定消费组信息。list_consumer_group 查询指定Logstore的所有消费组。update_check_point ...
A list of consumer group.Each element contains the following attributes:id-The ID of the consumer group,It is formatted to<instance_id>:<consumer_id>.consumer_id-The name of the consumer group.remark-The remark of the ...
背景信息 Rebalance是 云消息队列 Kafka 版 对分区和Consumer Group之间的消费对应关系进行重分配的过程。消费客户端出现Rebalance可能是以下原因:当消费者主动新增订阅或者取消订阅时,会触发该Consumer Group内的Rebalance。当Topic的...
Description:Consumer group name Value:Fn:GetAtt:ConsumerGroup-ConsumerGroupName SubscriptionInstanceId:Description:Subscription instance ID Value:Fn:GetAtt:ConsumerGroup-SubscriptionInstanceId JSON 格式 {...
ConsumerGroupId:Description:The ID of the consumer group.Value:Fn:GetAtt:ConsumerGroup-ConsumerGroupId InstanceId:Description:The ID of the instance.Value:Fn:GetAtt:ConsumerGroup-InstanceId DeliveryOrderType:Description:...
ConsumerGroupIds:Description:The list of consumer group IDs.Value:Fn:GetAtt:ExtensionDataSource-ConsumerGroupIds ConsumerGroups:Description:The list of consumer groups.Value:Fn:GetAtt:ExtensionDataSource-ConsumerGroups ...
CREATE GROUP 是 CREATE ROLE 的一种别名。语法 CREATE GROUP name[[WITH]option[.]]其中 option 可以是:SUPERUSER|NOSUPERUSER|CREATEDB|NOCREATEDB|CREATEROLE|NOCREATEROLE|INHERIT|NOINHERIT|LOGIN|NOLOGIN|REPLICATION|NOREPLICATION...