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 <wangg...@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 <rungumpth...@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!*
