use StringIO

Author: zerosign

lib/kafka/lz4_codec.rb

@@ -15,7 +15,8 @@ def compress(data)
     end
 
     def decompress(data)
-      LZ4::uncompress(data)
+      buffer = StringIO.new(data)
+      LZ4::uncompress(buffer)
     end
   end
 end