Sha256: b010e6a742ec9d6fb61270adb21944a33a3a408ae497046f456fd8cb69be9f7d
Contents?: true
Size: 392 Bytes
Versions: 8
Compression:
Stored size: 392 Bytes
Contents
module Kafka
module Protocol
class DeleteTopicsResponse
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
8 entries across 8 versions & 1 rubygems