class Kafka::Protocol::SyncGroupResponse
Attributes
error_code[R]
member_assignment[R]
Public Class Methods
decode(decoder)
click to toggle source
# File lib/kafka/protocol/sync_group_response.rb, line 15 def self.decode(decoder) error_code = decoder.int16 member_assignment_bytes = decoder.bytes new( error_code: error_code, member_assignment: member_assignment_bytes ? MemberAssignment.decode(Decoder.from_string(member_assignment_bytes)) : nil ) end
new(error_code:, member_assignment:)
click to toggle source
# File lib/kafka/protocol/sync_group_response.rb, line 10 def initialize(error_code:, member_assignment:) @error_code = error_code @member_assignment = member_assignment end