Re: Error handling in async Producer

2014-03-12 Thread Jun Rao
If all brokers are down, the async send will fail. In trunk, we have a new producer written in java, which allows the caller to register a callback during async send. Thanks, Jun On Wed, Mar 12, 2014 at 6:52 AM, Yury Ruchin wrote: > Hi, > > Having Kafka 0.8, I send messages using Producer in

Re: Error handling in async Producer

2014-03-12 Thread Viktor Kolodrevskiy
I had similar questions some time ago. Here's answer I've got: > In Kafka, we detect failures using ZK. So, if the network connectivity btw > the producer and the broker is down, but the one btw the broker and ZK is > up, we assume the broker is still alive and will continue to send the data > to

Error handling in async Producer

2014-03-12 Thread Yury Ruchin
Hi, Having Kafka 0.8, I send messages using Producer in async mode. I wonder what will happen if a message cannot be sent (e. g. all brokers get down). In sync mode, error handling is straightforward: after "message.send.max.retries" the send() method will throw FailedToSendMessageException. Howe