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