class Kafka::Protocol::TxnOffsetCommitResponse

Attributes

errors[R]

Public Class Methods

decode(decoder) click to toggle source
# File lib/kafka/protocol/txn_offset_commit_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/txn_offset_commit_response.rb, line 26
def initialize(errors:)
  @errors = errors
end