Sha256: 5bd6117fac7491cb7e9ed40f079c6e659e6f9f7ced73dcf1e16cca36fe868323
Contents?: true
Size: 347 Bytes
Versions: 9
Compression:
Stored size: 347 Bytes
Contents
module Kafka
module Protocol
class TxnOffsetCommitResponse
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
9 entries across 9 versions & 1 rubygems