celikfatih opened a new pull request, #20668: URL: https://github.com/apache/kafka/pull/20668
Kafka streams do not catch Error types that occur during `GlobalStreamThread` initiation, and therefore it is not possible to trace the error (for example, an `ExceptionInInitializerError` occurs when RocksDB is not found for the Global Store). This is because errors are not caught and logged. The catch block in `GlobalStreamThread#initialize()` has been ensured to catch `Throwable` instead of `Exception`. Additionally, the empty `setUncaughtHandler` set operation that prevented this from taking effect when users employed setUncaughtExceptionHandler has been removed. For the test scenario; It was demonstrated that whenever any `Throwable` occurs, this `Throwable` is correctly wrapped with `StreamsException` and the stream initiation transitions to an `DEAD` state. @mjsax @cadonna May I ask you to check the changes? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
