class Kafka::DeliveryFailed

Raised if not all messages could be sent by a producer.

def initialize(message, failed_messages) 

def initialize(message, failed_messages)
  @failed_messages = failed_messages
  super(message)
end