Handle partial messages at the end of a message set

As an optimization, Kafka brokers are allowed to include partial
messages at the end of a message set -- these should be ignored by
clients.

lib/kafka/protocol/message_set.rb

@@ -27,13 +27,17 @@ def self.decode(decoder)
         fetched_messages = []
 
         until decoder.eof?
-          message = Message.decode(decoder)
-
-          if message.compressed?
-            wrapped_message_set = message.decompress
-            fetched_messages.concat(wrapped_message_set.messages)
-          else
-            fetched_messages << message
+          begin
+            message = Message.decode(decoder)
+
+            if message.compressed?
+              wrapped_message_set = message.decompress
+              fetched_messages.concat(wrapped_message_set.messages)
+            else
+              fetched_messages << message
+            end
+          rescue EOFError
+            # We tried to decode a partial message; just skip it.
           end
         end