kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Pariksheet Barapatre <pari.data...@gmail.com>
Subject Kafka Streaming Question : reset offset
Date Wed, 20 Jul 2016 11:57:16 GMT
Hi Experts,

I have written Kafka Streaming app that just filters rows based on some
condition and load it to MongoDB.

The streaming process is working fine but due to some flaw in my code, I
want to reprocess whole data again.

One way is to do this -  kill streaming app , change consumer group id ,
delete data from mongo and rerun the app.

How to achieve this scenario without changing consumer group id.

Many Thanks
Pari

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