use extlz4

Author: zerosign

lib/kafka/lz4_codec.rb

@@ -1,22 +1,21 @@
 module Kafka
   class LZ4Codec
     def initialize
-      require "lz4-ruby"
+      require "extlz4"
     rescue LoadError
-      raise LoadError, "using lz4 compression requires adding a dependency on the `lz4-ruby` gem to your Gemfile."
+      raise LoadError, "using lz4 compression requires adding a dependency on the `extlz4` gem to your Gemfile."
     end
 
     def codec_id
       3
     end
 
     def compress(data)
-      LZ4::compress(data)
+      LZ4.encode(data)
     end
 
     def decompress(data)
-      buffer = StringIO.new(data)
-      LZ4::uncompress(buffer)
+      LZ4.decode(data)
     end
   end
 end

ruby-kafka.gemspec

@@ -35,7 +35,7 @@ Gem::Specification.new do |spec|
   spec.add_development_dependency "rspec-benchmark"
   spec.add_development_dependency "activesupport"
   spec.add_development_dependency "snappy"
-  spec.add_development_dependency "lz4-ruby"
+  spec.add_development_dependency "extlz4"
   spec.add_development_dependency "colored"
   spec.add_development_dependency "rspec_junit_formatter", "0.2.2"
   spec.add_development_dependency "dogstatsd-ruby", ">= 3.0.0"