public void setStreamsUncaughtExceptionHandler(final BiConsumer<Throwable, Boolean> streamsUncaughtExceptionHandler) {
        this.streamsUncaughtExceptionHandler = streamsUncaughtExceptionHandler;
    }
Sets the streams uncaught exception handler.

@param streamsUncaughtExceptionHandler the user handler wrapped in shell to execute the action
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java