Hi guys, I have a kotlin App that run 5 streams with different application.id, like:
my-app-stream1 my-app-stream2 some days a go I start experimenting, a very weird problem, all my streams are in running state then in 3-5 minutes transition to shut down, I enable the debug/trace logs, but I can't see any exception or error. I have the setUncaughtExceptionHandler set with a log, but it's never executed. So there are no exceptions inside the stream. I already try to disable all my streams and just keep one not smart with a foreach logging and the same happen, also I revert my code to a previous state and the same happen. I'm not able to reproduce in my local environment, this is happened to me on production. All the streams just change the state from running to pending shutdown I only have some small logs like State transition from RUNNING to PENDING_SHUTDOWN ..... State transition from PENDING_SHUTDOWN to NOT_RUNNING .... Waiting for the I/O thread to exit. Hard shutdown in 31536000000 ms. ... Flushing all global globalStores registered in the state manager ... Global thread has died. The streams application or client will now close to ERROR ..... Kafka consumer has been closed .... Exiting AdminClientRunnable any ideas? Thanks guys!!
