class Kafka::GzipCodec
Public Instance Methods
codec_id()
click to toggle source
# File lib/kafka/gzip_codec.rb, line 5 def codec_id 1 end
compress(data)
click to toggle source
# File lib/kafka/gzip_codec.rb, line 17 def compress(data) buffer = StringIO.new buffer.set_encoding(Encoding::BINARY) writer = Zlib::GzipWriter.new(buffer, Zlib::DEFAULT_COMPRESSION, Zlib::DEFAULT_STRATEGY) writer.write(data) writer.close buffer.string end
decompress(data)
click to toggle source
# File lib/kafka/gzip_codec.rb, line 28 def decompress(data) buffer = StringIO.new(data) reader = Zlib::GzipReader.new(buffer) reader.read end
load()
click to toggle source
# File lib/kafka/gzip_codec.rb, line 13 def load require "zlib" end
produce_api_min_version()
click to toggle source
# File lib/kafka/gzip_codec.rb, line 9 def produce_api_min_version 0 end