kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From noodles <rungumpth...@gmail.com>
Subject Re: How to mark a message as needing to retry in Kafka?
Date Thu, 29 Jan 2015 02:26:48 GMT
I did not describe my problem clearly. In my case, I got the message from
Kakfa, but I could not handle this message because of some reason, for
example the external server is down. So I want to mark the message as not
being consumed directly.

2015-01-28 23:26 GMT+08:00 Guozhang Wang <wangguoz@gmail.com>:

> Hi,
>
> Which consumer are you using? If you are using a high level consumer then
> retry would be automatic upon network exceptions.
>
> Guozhang
>
> On Wed, Jan 28, 2015 at 1:32 AM, noodles <rungumpth000@gmail.com> wrote:
>
> > Hi group:
> >
> > I'm working for building a webhook notification service based on Kafka. I
> > produce all of the payloads into Kafka, and consumers consume these
> > payloads by offset.
> >
> > Sometimes some payloads cannot be consumed because of network exception
> or
> > http server exception. So I want to mark the failed payloads and retry
> them
> > by timers. But I have no idea if I don't use a storage (like MySQL)
> except
> > kafka and zookeeper.
> >
> >
> > --
> > *noodles!*
> >
>
>
>
> --
> -- Guozhang
>



-- 
*Yeah, I'm noodles!*

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message