Exception: Kafka::DeliveryFailed

Inherits:
Error
  • Object
show all
Defined in:
lib/kafka.rb

Overview

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

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(message, failed_messages) ⇒ DeliveryFailed

Returns a new instance of DeliveryFailed.



332
333
334
335
336
 
# 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.



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

def failed_messages
  @failed_messages
end