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 19
def compress(data)
  LZ4.encode(data)
end
decompress(data) click to toggle source
# File lib/kafka/lz4_codec.rb, line 23
def decompress(data)
  LZ4.decode(data)
end
load() click to toggle source
# File lib/kafka/lz4_codec.rb, line 13
def load
  require "extlz4"
rescue LoadError
  raise LoadError, "using lz4 compression requires adding a dependency on the `extlz4` gem to your Gemfile."
end
produce_api_min_version() click to toggle source
# File lib/kafka/lz4_codec.rb, line 9
def produce_api_min_version
  0
end