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 13
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 24
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 9
def load
  require "zlib"
end