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