Sha256: 93e8934a4d1eec97881a2e01c90c993096cb4b2a5229ab2434727fa51efd1887
Contents?: true
Size: 1.03 KB
Versions: 33
Compression:
Stored size: 1.03 KB
Contents
# frozen_string_literal: true module Kafka module Protocol class AddPartitionsToTxnResponse class PartitionError attr_reader :partition, :error_code def initialize(partition:, error_code:) @partition = partition @error_code = error_code end end class TopicPartitionsError attr_reader :topic, :partitions def initialize(topic:, partitions:) @topic = topic @partitions = partitions end end attr_reader :errors def initialize(errors:) @errors = errors end def self.decode(decoder) _throttle_time_ms = decoder.int32 errors = decoder.array do TopicPartitionsError.new( topic: decoder.string, partitions: decoder.array do PartitionError.new( partition: decoder.int32, error_code: decoder.int16 ) end ) end new(errors: errors) end end end end
Version data entries
33 entries across 33 versions & 4 rubygems