Class: TencentCloud::Ckafka::V20190819::GroupInfoResponse

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

Overview

GroupInfo返回数据的实体

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(errorcode = nil, state = nil, protocoltype = nil, protocol = nil, members = nil, group = nil) ⇒ GroupInfoResponse

Returns a new instance of GroupInfoResponse.



7338
7339
7340
7341
7342
7343
7344
7345
# File 'lib/v20190819/models.rb', line 7338

def initialize(errorcode=nil, state=nil, protocoltype=nil, protocol=nil, members=nil, group=nil)
  @ErrorCode = errorcode
  @State = state
  @ProtocolType = protocoltype
  @Protocol = protocol
  @Members = members
  @Group = group
end

Instance Attribute Details

#ErrorCodeObject

Dead:消费分组不存在 Empty:消费分组,当前没有任何消费者订阅 PreparingRebalance:消费分组处于 rebalance 状态 CompletingRebalance:消费分组处于 rebalance 状态 Stable:消费分组中各个消费者已经加入,处于稳定状态

Parameters:

  • ErrorCode:

    错误码,正常为0

  • State:

    group 状态描述(常见的为 Empty、Stable、Dead 三种状态):

  • ProtocolType:

    消费分组选择的协议类型正常的消费者一般为 consumer 但有些系统采用了自己的协议如 kafka-connect 用的就是 connect。只有标准的 consumer 协议,本接口才知道具体的分配方式的格式,才能解析到具体的 partition 的分配情况

  • Protocol:

    消费者 partition 分配算法常见的有如下几种(Kafka 消费者 SDK 默认的选择项为 range):range、 roundrobin、 sticky

  • Members:

    仅当 state 为 Stable 且 protocol_type 为 consumer 时, 该数组才包含信息

  • Group:

    消费分组名称



7336
7337
7338
# File 'lib/v20190819/models.rb', line 7336

def ErrorCode
  @ErrorCode
end

#GroupObject

Dead:消费分组不存在 Empty:消费分组,当前没有任何消费者订阅 PreparingRebalance:消费分组处于 rebalance 状态 CompletingRebalance:消费分组处于 rebalance 状态 Stable:消费分组中各个消费者已经加入,处于稳定状态

Parameters:

  • ErrorCode:

    错误码,正常为0

  • State:

    group 状态描述(常见的为 Empty、Stable、Dead 三种状态):

  • ProtocolType:

    消费分组选择的协议类型正常的消费者一般为 consumer 但有些系统采用了自己的协议如 kafka-connect 用的就是 connect。只有标准的 consumer 协议,本接口才知道具体的分配方式的格式,才能解析到具体的 partition 的分配情况

  • Protocol:

    消费者 partition 分配算法常见的有如下几种(Kafka 消费者 SDK 默认的选择项为 range):range、 roundrobin、 sticky

  • Members:

    仅当 state 为 Stable 且 protocol_type 为 consumer 时, 该数组才包含信息

  • Group:

    消费分组名称



7336
7337
7338
# File 'lib/v20190819/models.rb', line 7336

def Group
  @Group
end

#MembersObject

Dead:消费分组不存在 Empty:消费分组,当前没有任何消费者订阅 PreparingRebalance:消费分组处于 rebalance 状态 CompletingRebalance:消费分组处于 rebalance 状态 Stable:消费分组中各个消费者已经加入,处于稳定状态

Parameters:

  • ErrorCode:

    错误码,正常为0

  • State:

    group 状态描述(常见的为 Empty、Stable、Dead 三种状态):

  • ProtocolType:

    消费分组选择的协议类型正常的消费者一般为 consumer 但有些系统采用了自己的协议如 kafka-connect 用的就是 connect。只有标准的 consumer 协议,本接口才知道具体的分配方式的格式,才能解析到具体的 partition 的分配情况

  • Protocol:

    消费者 partition 分配算法常见的有如下几种(Kafka 消费者 SDK 默认的选择项为 range):range、 roundrobin、 sticky

  • Members:

    仅当 state 为 Stable 且 protocol_type 为 consumer 时, 该数组才包含信息

  • Group:

    消费分组名称



7336
7337
7338
# File 'lib/v20190819/models.rb', line 7336

def Members
  @Members
end

#ProtocolObject

Dead:消费分组不存在 Empty:消费分组,当前没有任何消费者订阅 PreparingRebalance:消费分组处于 rebalance 状态 CompletingRebalance:消费分组处于 rebalance 状态 Stable:消费分组中各个消费者已经加入,处于稳定状态

Parameters:

  • ErrorCode:

    错误码,正常为0

  • State:

    group 状态描述(常见的为 Empty、Stable、Dead 三种状态):

  • ProtocolType:

    消费分组选择的协议类型正常的消费者一般为 consumer 但有些系统采用了自己的协议如 kafka-connect 用的就是 connect。只有标准的 consumer 协议,本接口才知道具体的分配方式的格式,才能解析到具体的 partition 的分配情况

  • Protocol:

    消费者 partition 分配算法常见的有如下几种(Kafka 消费者 SDK 默认的选择项为 range):range、 roundrobin、 sticky

  • Members:

    仅当 state 为 Stable 且 protocol_type 为 consumer 时, 该数组才包含信息

  • Group:

    消费分组名称



7336
7337
7338
# File 'lib/v20190819/models.rb', line 7336

def Protocol
  @Protocol
end

#ProtocolTypeObject

Dead:消费分组不存在 Empty:消费分组,当前没有任何消费者订阅 PreparingRebalance:消费分组处于 rebalance 状态 CompletingRebalance:消费分组处于 rebalance 状态 Stable:消费分组中各个消费者已经加入,处于稳定状态

Parameters:

  • ErrorCode:

    错误码,正常为0

  • State:

    group 状态描述(常见的为 Empty、Stable、Dead 三种状态):

  • ProtocolType:

    消费分组选择的协议类型正常的消费者一般为 consumer 但有些系统采用了自己的协议如 kafka-connect 用的就是 connect。只有标准的 consumer 协议,本接口才知道具体的分配方式的格式,才能解析到具体的 partition 的分配情况

  • Protocol:

    消费者 partition 分配算法常见的有如下几种(Kafka 消费者 SDK 默认的选择项为 range):range、 roundrobin、 sticky

  • Members:

    仅当 state 为 Stable 且 protocol_type 为 consumer 时, 该数组才包含信息

  • Group:

    消费分组名称



7336
7337
7338
# File 'lib/v20190819/models.rb', line 7336

def ProtocolType
  @ProtocolType
end

#StateObject

Dead:消费分组不存在 Empty:消费分组,当前没有任何消费者订阅 PreparingRebalance:消费分组处于 rebalance 状态 CompletingRebalance:消费分组处于 rebalance 状态 Stable:消费分组中各个消费者已经加入,处于稳定状态

Parameters:

  • ErrorCode:

    错误码,正常为0

  • State:

    group 状态描述(常见的为 Empty、Stable、Dead 三种状态):

  • ProtocolType:

    消费分组选择的协议类型正常的消费者一般为 consumer 但有些系统采用了自己的协议如 kafka-connect 用的就是 connect。只有标准的 consumer 协议,本接口才知道具体的分配方式的格式,才能解析到具体的 partition 的分配情况

  • Protocol:

    消费者 partition 分配算法常见的有如下几种(Kafka 消费者 SDK 默认的选择项为 range):range、 roundrobin、 sticky

  • Members:

    仅当 state 为 Stable 且 protocol_type 为 consumer 时, 该数组才包含信息

  • Group:

    消费分组名称



7336
7337
7338
# File 'lib/v20190819/models.rb', line 7336

def State
  @State
end

Instance Method Details

#deserialize(params) ⇒ Object



7347
7348
7349
7350
7351
7352
7353
7354
7355
7356
7357
7358
7359
7360
7361
# File 'lib/v20190819/models.rb', line 7347

def deserialize(params)
  @ErrorCode = params['ErrorCode']
  @State = params['State']
  @ProtocolType = params['ProtocolType']
  @Protocol = params['Protocol']
  unless params['Members'].nil?
    @Members = []
    params['Members'].each do |i|
      groupinfomember_tmp = GroupInfoMember.new
      groupinfomember_tmp.deserialize(i)
      @Members << groupinfomember_tmp
    end
  end
  @Group = params['Group']
end