lib/kafka.rb in ruby-kafka-0.7.0.alpha1 vs lib/kafka.rb in ruby-kafka-0.7.0.alpha2

@@ -40,9 +40,13 @@
 
   # This indicates that a message contents does not match its CRC.
   class CorruptMessage < ProtocolError
   end
 
+  # When the record array length doesn't match real number of received records
+  class InsufficientDataMessage < Error
+  end
+
   class UnknownError < ProtocolError
   end
 
   class OffsetOutOfRange < ProtocolError
     attr_accessor :topic, :partition, :offset