class Kafka::Protocol::JoinGroupResponse

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 21
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 { [decoder.string, decoder.bytes] }],
  )
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 12
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