It may be too late to change the Producer API now.
I always find "ListenableFuture" is very nice/usable. It essentially adds
callback to Future. It's a lot easier to chain/combine ListenableFuture.
http://docs.guava-libraries.googlecode.com/git/javadoc/com/google/common/util/concurrent/ListenableFuture.html
On Wed, Sep 24, 2014 at 6:05 PM, Guozhang Wang wrote:
> Hi,
>
> In the new (Java) producer, you can pass in a callback function in the
>
> Future 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
>
