Class: TencentCloud::Dts::V20211206::ResetConsumerGroupOffsetRequest

Inherits:
Common::AbstractModel
  • Object
show all
Defined in:
lib/v20211206/models.rb

Overview

ResetConsumerGroupOffset请求参数结构体

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(subscribeid = nil, topicname = nil, consumergroupname = nil, partitionnos = nil, resetmode = nil, resetdatetime = nil) ⇒ ResetConsumerGroupOffsetRequest

Returns a new instance of ResetConsumerGroupOffsetRequest.



6222
6223
6224
6225
6226
6227
6228
6229
# File 'lib/v20211206/models.rb', line 6222

def initialize(subscribeid=nil, topicname=nil, consumergroupname=nil, partitionnos=nil, resetmode=nil, resetdatetime=nil)
  @SubscribeId = subscribeid
  @TopicName = topicname
  @ConsumerGroupName = consumergroupname
  @PartitionNos = partitionnos
  @ResetMode = resetmode
  @ResetDatetime = resetdatetime
end

Instance Attribute Details

#ConsumerGroupNameObject

Parameters:

  • 订阅实例id,可通过DescribeSyncJobs接口获取。

  • 订阅的kafka topic,可通过DescribeSyncJobs接口获取。

  • 消费组名称。实际的消费组全称形如:consumer-grp-##SubscribeId-##ConsumerGroupName。可通过DescribeConsumerGroups接口获取。

  • 需要修改offset的分区编号,可通过DescribeOffsetByTime接口获取。

  • 重置方式。枚举值为 earliest-从最开始位置开始消费;latest-从最新位置开始消费;datetime-从指定时间前最近的checkpoint开始消费

  • 当 ResetMode 为 datetime 时,该项需要填,格式为:Y-m-d h:m:s。如果不填,默认用0时间,效果与earliest相同。



6220
6221
6222
# File 'lib/v20211206/models.rb', line 6220

def ConsumerGroupName
  @ConsumerGroupName
end

#PartitionNosObject

Parameters:

  • 订阅实例id,可通过DescribeSyncJobs接口获取。

  • 订阅的kafka topic,可通过DescribeSyncJobs接口获取。

  • 消费组名称。实际的消费组全称形如:consumer-grp-##SubscribeId-##ConsumerGroupName。可通过DescribeConsumerGroups接口获取。

  • 需要修改offset的分区编号,可通过DescribeOffsetByTime接口获取。

  • 重置方式。枚举值为 earliest-从最开始位置开始消费;latest-从最新位置开始消费;datetime-从指定时间前最近的checkpoint开始消费

  • 当 ResetMode 为 datetime 时,该项需要填,格式为:Y-m-d h:m:s。如果不填,默认用0时间,效果与earliest相同。



6220
6221
6222
# File 'lib/v20211206/models.rb', line 6220

def PartitionNos
  @PartitionNos
end

#ResetDatetimeObject

Parameters:

  • 订阅实例id,可通过DescribeSyncJobs接口获取。

  • 订阅的kafka topic,可通过DescribeSyncJobs接口获取。

  • 消费组名称。实际的消费组全称形如:consumer-grp-##SubscribeId-##ConsumerGroupName。可通过DescribeConsumerGroups接口获取。

  • 需要修改offset的分区编号,可通过DescribeOffsetByTime接口获取。

  • 重置方式。枚举值为 earliest-从最开始位置开始消费;latest-从最新位置开始消费;datetime-从指定时间前最近的checkpoint开始消费

  • 当 ResetMode 为 datetime 时,该项需要填,格式为:Y-m-d h:m:s。如果不填,默认用0时间,效果与earliest相同。



6220
6221
6222
# File 'lib/v20211206/models.rb', line 6220

def ResetDatetime
  @ResetDatetime
end

#ResetModeObject

Parameters:

  • 订阅实例id,可通过DescribeSyncJobs接口获取。

  • 订阅的kafka topic,可通过DescribeSyncJobs接口获取。

  • 消费组名称。实际的消费组全称形如:consumer-grp-##SubscribeId-##ConsumerGroupName。可通过DescribeConsumerGroups接口获取。

  • 需要修改offset的分区编号,可通过DescribeOffsetByTime接口获取。

  • 重置方式。枚举值为 earliest-从最开始位置开始消费;latest-从最新位置开始消费;datetime-从指定时间前最近的checkpoint开始消费

  • 当 ResetMode 为 datetime 时,该项需要填,格式为:Y-m-d h:m:s。如果不填,默认用0时间,效果与earliest相同。



6220
6221
6222
# File 'lib/v20211206/models.rb', line 6220

def ResetMode
  @ResetMode
end

#SubscribeIdObject

Parameters:

  • 订阅实例id,可通过DescribeSyncJobs接口获取。

  • 订阅的kafka topic,可通过DescribeSyncJobs接口获取。

  • 消费组名称。实际的消费组全称形如:consumer-grp-##SubscribeId-##ConsumerGroupName。可通过DescribeConsumerGroups接口获取。

  • 需要修改offset的分区编号,可通过DescribeOffsetByTime接口获取。

  • 重置方式。枚举值为 earliest-从最开始位置开始消费;latest-从最新位置开始消费;datetime-从指定时间前最近的checkpoint开始消费

  • 当 ResetMode 为 datetime 时,该项需要填,格式为:Y-m-d h:m:s。如果不填,默认用0时间,效果与earliest相同。



6220
6221
6222
# File 'lib/v20211206/models.rb', line 6220

def SubscribeId
  @SubscribeId
end

#TopicNameObject

Parameters:

  • 订阅实例id,可通过DescribeSyncJobs接口获取。

  • 订阅的kafka topic,可通过DescribeSyncJobs接口获取。

  • 消费组名称。实际的消费组全称形如:consumer-grp-##SubscribeId-##ConsumerGroupName。可通过DescribeConsumerGroups接口获取。

  • 需要修改offset的分区编号,可通过DescribeOffsetByTime接口获取。

  • 重置方式。枚举值为 earliest-从最开始位置开始消费;latest-从最新位置开始消费;datetime-从指定时间前最近的checkpoint开始消费

  • 当 ResetMode 为 datetime 时,该项需要填,格式为:Y-m-d h:m:s。如果不填,默认用0时间,效果与earliest相同。



6220
6221
6222
# File 'lib/v20211206/models.rb', line 6220

def TopicName
  @TopicName
end

Instance Method Details

#deserialize(params) ⇒ Object



6231
6232
6233
6234
6235
6236
6237
6238
# File 'lib/v20211206/models.rb', line 6231

def deserialize(params)
  @SubscribeId = params['SubscribeId']
  @TopicName = params['TopicName']
  @ConsumerGroupName = params['ConsumerGroupName']
  @PartitionNos = params['PartitionNos']
  @ResetMode = params['ResetMode']
  @ResetDatetime = params['ResetDatetime']
end