Hi Yonghui, If you set producer.type = sync, then the send() call will not return until it have received the ack from the broker, and if the response contains any error code it will re-try send until all retries exhausted, and then will throw an exception.
Guozhang On Fri, May 9, 2014 at 4:18 AM, Yonghui Zhao <[email protected]> wrote: > Seems email archive doesn't work now in > http://mail-archives.apache.org/mod_mbox/kafka-users/201405.mbox/browser > > And also I sent email to [email protected] to subscribe > this group, it doesn't work either. > > > 2014-05-09 16:00 GMT+08:00 Yonghui Zhao <[email protected]>: > > > > > 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? > > > > > -- -- Guozhang
