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.



212
213
214
215
216
 
# File 'lib/kafka.rb', line 212

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.



210
211
212
 
# File 'lib/kafka.rb', line 210

def failed_messages
  @failed_messages
end