Sha256: 9baaf17d3e9595f2d3740a51334fc8b8dced3a5e3a5d5dc17346edad2de3964b
Contents?: true
Size: 423 Bytes
Versions: 49
Compression:
Stored size: 423 Bytes
Contents
# frozen_string_literal: true 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
49 entries across 49 versions & 4 rubygems