class Kafka::Protocol::CreateTopicsResponse
Attributes
errors[R]
Public Class Methods
decode(decoder)
click to toggle source
# File lib/kafka/protocol/create_topics_response.rb, line 13 def self.decode(decoder) errors = decoder.array do topic = decoder.string error_code = decoder.int16 [topic, error_code] end new(errors: errors) end
new(errors:)
click to toggle source
# File lib/kafka/protocol/create_topics_response.rb, line 9 def initialize(errors:) @errors = errors end