Sha256: 724255a265036fbb735babedb062d2e06dda615b0205ab303e0a25af90db1178
Contents?: true
Size: 623 Bytes
Versions: 49
Compression:
Stored size: 623 Bytes
Contents
# frozen_string_literal: true
module Kafka
module Protocol
class CreatePartitionsResponse
attr_reader :errors
def initialize(throttle_time_ms:, errors:)
@throttle_time_ms = throttle_time_ms
@errors = errors
end
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
end
end
end
Version data entries
49 entries across 49 versions & 4 rubygems