Exception: Kafka::DeliveryFailed

Inherits:

Error

• Object
• StandardError
• Error
• Kafka::DeliveryFailed

Defined in:

lib/kafka.rb

Overview

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

Instance Attribute Summary

• #failed_messages ⇒ Object readonly

  Returns the value of attribute failed_messages.

Instance Method Summary

• #initialize(message, failed_messages) ⇒ DeliveryFailed constructor

  A new instance of DeliveryFailed.

Constructor Details

#initialize(message, failed_messages) ⇒ DeliveryFailed

Returns a new instance of DeliveryFailed.

# File 'lib/kafka.rb', line 332

def initialize(message, failed_messages)
  @failed_messages = failed_messages

  super(message)
end

Instance Attribute Details

#failed_messages ⇒ Object (readonly)

Returns the value of attribute failed_messages.

# File 'lib/kafka.rb', line 330

def failed_messages
  @failed_messages
end