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) new( error_code: decoder.int16, member_assignment: MemberAssignment.decode(Decoder.from_string(decoder.bytes)), ) 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