class Kafka::Protocol::AddPartitionsToTxnResponse
Attributes
errors[R]
Public Class Methods
decode(decoder)
click to toggle source
# File lib/kafka/protocol/add_partitions_to_txn_response.rb, line 30 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
new(errors:)
click to toggle source
# File lib/kafka/protocol/add_partitions_to_txn_response.rb, line 26 def initialize(errors:) @errors = errors end