Yes, in sync mode, if send() fails, an exception will be thrown.
Thanks,
Jun
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.KeyedMessageK,V message) { /* compiled
code */ }
How to know
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
If l use java producer api in sync mode.
public void send(kafka.producer.KeyedMessageK,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?
