Hi, In the new (Java) producer, you can pass in a callback function in the
Future<RecordMetadata> send(ProducerRecord record, Callback callback) call, which will be triggered when the ack is received. Alternatively, you can also call Future.get() on the returned future metadata, which will block until the ack is received (i.e., synced sending). Guozhang On Wed, Sep 24, 2014 at 6:10 AM, Sreenivasulu Nallapati < sreenu.nallap...@gmail.com> wrote: > Hello, > > Can you please help me to get the acknowledgement in producer? > > > After setting the property *request.required.acks to 1, *how producer gets > the acknowledgement back? I am trying to get the acknowledgement in java > producer. > > > > > > Thanks > > Sreeni > -- -- Guozhang
