Many Thanks Matthias for update. Regards Pari
On 20 July 2016 at 17:48, Matthias J. Sax <[email protected]> wrote: > Hi Pari, > > currently, changing the application ID is the best way to follow. > Cleaning up the application state correctly, is a little bit tricky. We > are currently working on an improvement for this -- should be available > soon. > > See https://issues.apache.org/jira/browse/KAFKA-3185 > > > -Matthias > > On 07/20/2016 01:57 PM, Pariksheet Barapatre wrote: > > 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 > > > >
