class Kafka::Protocol::EndTxnResposne
Attributes
error_code[R]
Public Class Methods
decode(decoder)
click to toggle source
# File lib/kafka/protocol/end_txn_response.rb, line 12 def self.decode(decoder) _throttle_time_ms = decoder.int32 error_code = decoder.int16 new(error_code: error_code) end
new(error_code:)
click to toggle source
# File lib/kafka/protocol/end_txn_response.rb, line 8 def initialize(error_code:) @error_code = error_code end