It typically throws a exception in the end of the sync producer cannot
deliver your message.
In the case where there is a IOException or similiar exceptions that
the Broker cannot deal with, I believe it will try to return
UnknownError response which will then throw in the producer.
In cases where it receives error codes where the producer can recover
from (ie: NotLeaderForPartition), it simply retries up to the
configured max retries.
Tim
On Fri, May 9, 2014 at 1:00 AM, Yonghui Zhao <zhaoyong...@gmail.com> wrote:
> If l use java producer api in sync mode.
>
> public void send(kafka.producer.KeyedMessage<K,V> message) { /* compiled
> code */ }
>
> How to know whether a send process is successful or failed?
>
> For example if the kafka broker disk is not accessible , will it throw
> exceptions?
