The problem that I am facing is my Kafka Stream(1 thread) goes down unexpectedly due to some error. What I want to do is that if there is an error in Kafka stream consumer, it is identified and the stream is restarted automatically via a cron so that it removes the pain of constantly monitoring it. Is there any appropriate way to do this?
Until now I have tried using stream.start() on the same stream instance that got the error but it didn't work.