class Kafka::Protocol::JoinGroupResponse

Constants

Metadata

Attributes

error_code[R]
generation_id[R]
group_protocol[R]
leader_id[R]
member_id[R]
members[R]

Public Class Methods

decode(decoder) click to toggle source
# File lib/kafka/protocol/join_group_response.rb, line 23
def self.decode(decoder)
  new(
    error_code: decoder.int16,
    generation_id: decoder.int32,
    group_protocol: decoder.string,
    leader_id: decoder.string,
    member_id: decoder.string,
    members: Hash[
      decoder.array do
        member_id = decoder.string
        d = Decoder.from_string(decoder.bytes)
        [member_id, Metadata.new(d.int16, d.array { d.string }, d.bytes)]
      end
    ],
  )
end
new(error_code:, generation_id:, group_protocol:, leader_id:, member_id:, members:) click to toggle source
# File lib/kafka/protocol/join_group_response.rb, line 14
def initialize(error_code:, generation_id:, group_protocol:, leader_id:, member_id:, members:)
  @error_code = error_code
  @generation_id = generation_id
  @group_protocol = group_protocol
  @leader_id = leader_id
  @member_id = member_id
  @members = members
end