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 16 def compress(data) Snappy.deflate(data) end
decompress(data)
click to toggle source
# File lib/kafka/snappy_codec.rb, line 20 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 9 def load require "snappy" rescue LoadError raise LoadError, "Using snappy compression requires adding a dependency on the `snappy` gem to your Gemfile." end