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