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