class Kafka::Protocol::DescribeGroupsResponse

Attributes

error_code[R]
groups[R]

Public Class Methods

decode(decoder) click to toggle source
# File lib/kafka/protocol/describe_groups_response.rb, line 36
def self.decode(decoder)
  groups = decoder.array do
    error_code = decoder.int16
    group_id = decoder.string
    state = decoder.string
    protocol_type = decoder.string
    protocol = decoder.string

    members = decoder.array do
      member_id = decoder.string
      client_id = decoder.string
      client_host = decoder.string
      _metadata = decoder.bytes
      assignment = MemberAssignment.decode(Decoder.from_string(decoder.bytes))

      Member.new(
        member_id: member_id,
        client_id: client_id,
        client_host: client_host,
        member_assignment: assignment
      )
    end

    Group.new(
      error_code: error_code,
      group_id: group_id,
      state: state,
      protocol_type: protocol_type,
      protocol: protocol,
      members: members
    )
  end

  new(groups: groups)
end
new(groups:) click to toggle source
# File lib/kafka/protocol/describe_groups_response.rb, line 32
def initialize(groups:)
  @groups = groups
end