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 >
signature.asc
Description: OpenPGP digital signature
