Sha256: 8b6d9f06cfd5cd933b1a8ff9392f3f5af88fefc1684fb5a56cd4d1757adc2cf2
Contents?: true
Size: 508 Bytes
Versions: 56
Compression:
Stored size: 508 Bytes
Contents
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
56 entries across 56 versions & 1 rubygems