class Kafka::SnappyCodec

Public Instance Methods

codec_id() click to toggle source
# File lib/kafka/snappy_codec.rb, line 5
def codec_id
  2
end
compress(data) click to toggle source
# File lib/kafka/snappy_codec.rb, line 20
def compress(data)
  Snappy.deflate(data)
end
decompress(data) click to toggle source
# File lib/kafka/snappy_codec.rb, line 24
def decompress(data)
  buffer = StringIO.new(data)
  Snappy::Reader.new(buffer).read
end
load() click to toggle source
# File lib/kafka/snappy_codec.rb, line 13
def load
  require "snappy"
rescue LoadError
  raise LoadError,
    "Using snappy compression requires adding a dependency on the `snappy` gem to your Gemfile."
end
produce_api_min_version() click to toggle source
# File lib/kafka/snappy_codec.rb, line 9
def produce_api_min_version
  0
end