lib/kafka.rb in ruby-kafka-0.4.2 vs lib/kafka.rb in ruby-kafka-0.4.3

@@ -201,9 +201,16 @@
   class BufferOverflow < Error
   end
 
   # Raised if not all messages could be sent by a producer.
   class DeliveryFailed < Error
+    attr_reader :failed_messages
+
+    def initialize(message, failed_messages)
+      @failed_messages = failed_messages
+
+      super(message)
+    end
   end
 
   class HeartbeatError < Error
   end