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