Sha256: 94ae14428fbed85055d61a30b61fdbebd37c7f5309f5dcd3c582bc216d094880
Contents?: true
Size: 539 Bytes
Versions: 40
Compression:
Stored size: 539 Bytes
Contents
# frozen_string_literal: true
require "kafka/protocol/member_assignment"
module Kafka
module Protocol
class SyncGroupResponse
attr_reader :error_code, :member_assignment
def initialize(error_code:, member_assignment:)
@error_code = error_code
@member_assignment = member_assignment
end
def self.decode(decoder)
new(
error_code: decoder.int16,
member_assignment: MemberAssignment.decode(Decoder.from_string(decoder.bytes)),
)
end
end
end
end
Version data entries
40 entries across 40 versions & 2 rubygems