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.



220
221
222
223
224
 
# File 'lib/kafka.rb', line 220

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.



218
219
220
 
# File 'lib/kafka.rb', line 218

def failed_messages
  @failed_messages
end