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