class WaterDrop::Errors::ProduceManyError
Raised when during messages producing something bad happened inline
Attributes
Public Class Methods
Source
# File lib/waterdrop/errors.rb, line 66 def initialize(dispatched, message) super(message) @dispatched = dispatched end
@param dispatched [Array<Rdkafka::Producer::DeliveryHandle>] handlers of the
messages that we've dispatched
@param message [String] error message
Calls superclass method