class Kafka::LZ4Codec
Public Instance Methods
codec_id()
click to toggle source
# File lib/kafka/lz4_codec.rb, line 5 def codec_id 3 end
compress(data)
click to toggle source
# File lib/kafka/lz4_codec.rb, line 15 def compress(data) LZ4.encode(data) end
decompress(data)
click to toggle source
# File lib/kafka/lz4_codec.rb, line 19 def decompress(data) LZ4.decode(data) end
load()
click to toggle source
# File lib/kafka/lz4_codec.rb, line 9 def load require "extlz4" rescue LoadError raise LoadError, "using lz4 compression requires adding a dependency on the `extlz4` gem to your Gemfile." end