You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Franco Giacosa <fg...@gmail.com> on 2016/02/11 11:59:24 UTC

Callback Record Key

Hi,

Is there a way to get the record key on the callback of the send() for a
record? I would like to be able to identify for which of the Records that I
have sent is the callback so I can ACK on the db that the record landed
successfully in kafka.

I am using 0.9.0.


Thanks.

Re: Callback Record Key

Posted by Franco Giacosa <fg...@gmail.com>.

Thanks Damian.

2016-02-11 12:01 GMT+01:00 Damian Guy <da...@gmail.com>:

> Hi,
> Pass the key into the callback you provide to kafka. You then have it
> available when the callback is invoked.
>
> Cheers,
> Damian
>
> On 11 February 2016 at 10:59, Franco Giacosa <fg...@gmail.com> wrote:
>
> > Hi,
> >
> > Is there a way to get the record key on the callback of the send() for a
> > record? I would like to be able to identify for which of the Records
> that I
> > have sent is the callback so I can ACK on the db that the record landed
> > successfully in kafka.
> >
> > I am using 0.9.0.
> >
> >
> > Thanks.
> >
>

Re: Callback Record Key

Posted by Damian Guy <da...@gmail.com>.

Hi,
Pass the key into the callback you provide to kafka. You then have it
available when the callback is invoked.

Cheers,
Damian

On 11 February 2016 at 10:59, Franco Giacosa <fg...@gmail.com> wrote:

> Hi,
>
> Is there a way to get the record key on the callback of the send() for a
> record? I would like to be able to identify for which of the Records that I
> have sent is the callback so I can ACK on the db that the record landed
> successfully in kafka.
>
> I am using 0.9.0.
>
>
> Thanks.
>