Sha256: 907b07d8ba392f47b9e34014db0fffd6c7c2a270a1398993075c8f32de86b080
Contents?: true
Size: 368 Bytes
Versions: 33
Compression:
Stored size: 368 Bytes
Contents
# frozen_string_literal: true
module Kafka
module Protocol
class EndTxnResposne
attr_reader :error_code
def initialize(error_code:)
@error_code = error_code
end
def self.decode(decoder)
_throttle_time_ms = decoder.int32
error_code = decoder.int16
new(error_code: error_code)
end
end
end
end
Version data entries
33 entries across 33 versions & 4 rubygems