@Override
    public void startup() {
        try {
            LOGGER.info("S3Storage starting");
            recover();
            LOGGER.info("S3Storage start completed");
        } catch (Throwable e) {
            LOGGER.error("S3Storage start fail", e);
            throw new RuntimeException(e);
        }
    }
Filter out invalid streams (the recovered start offset mismatches the stream end offset from controller) from the cache block if there are any.
s3stream/src/main/java/com/automq/stream/s3/S3Storage.java