handle() will throw the exception to the caller. In sync mode, client will
receive the exception, but in async mode, there's an independent thread
actually doing the sending. It's not easy to inform the caller except for
blocking the queue.
In practice, you can configure the retry times, and each t
Hello,
I am looking at 0.8.1.1, the kafka.producer.async.DefaultEventHandler
file. Below is the dispatchSerializedData function. Looks like we are
catching exception outside the loop and purely logs an error message.
We then return failedProduceRequests.
In case one broker is having problem, mess
