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
