Add a spec for Compression

Author: dasch

lib/kafka/compression.rb

@@ -4,12 +4,16 @@
 
 module Kafka
   module Compression
+    def self.codecs
+      [:snappy, :gzip, :lz4]
+    end
+
     def self.find_codec(name)
       case name
       when nil then nil
       when :snappy then SnappyCodec.new
       when :gzip then GzipCodec.new
-      when :lz4  then LZ4Codec.new
+      when :lz4 then LZ4Codec.new
       else raise "Unknown compression codec #{name}"
       end
     end

spec/compression_spec.rb

@@ -0,0 +1,12 @@
+describe Kafka::Compression do
+  Kafka::Compression.codecs.each do |codec_name|
+    describe codec_name.to_s do
+      it "encodes and decodes data" do
+        data = "yolo"
+        codec = Kafka::Compression.find_codec(codec_name)
+
+        expect(codec.decompress(codec.compress(data))).to eq data
+      end
+    end
+  end
+end