Sha256: f464ebfc528f7708b6b15e0b35159b2b5b47cbe3a15935279408ca3ac1b57bbd
Contents?: true
Size: 392 Bytes
Versions: 15
Compression:
Stored size: 392 Bytes
Contents
module Kafka
module Protocol
class CreateTopicsResponse
attr_reader :errors
def initialize(errors:)
@errors = errors
end
def self.decode(decoder)
errors = decoder.array do
topic = decoder.string
error_code = decoder.int16
[topic, error_code]
end
new(errors: errors)
end
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems