public static <T> CompletableFuture<T> exec(Supplier<CompletableFuture<T>> run, Logger logger, String name) {
        try {
            return run.get();
        } catch (Throwable ex) {
            logger.error("{} run with unexpected exception", name, ex);
            return failedFuture(ex);
        }
    }
Catch exceptions as a last resort to avoid unresponsiveness.
s3stream/src/main/java/com/automq/stream/utils/FutureUtil.java