protected UploadWriteAheadLogTask newUploadWriteAheadLogTask(Map<Long, List<StreamRecordBatch>> streamRecordsMap, ObjectManager objectManager, double rate) {
        return DefaultUploadWriteAheadLogTask.builder().config(config).streamRecordsMap(streamRecordsMap)
            .objectManager(objectManager).objectStorage(objectStorage).executor(uploadWALExecutor).rate(rate).build();
    }
Force upload stream WAL cache to S3. Use group upload to avoid generate too many S3 objects when broker shutdown.
{@code streamId} can be {@link LogCache#MATCH_ALL_STREAMS} to force upload all streams.
s3stream/src/main/java/com/automq/stream/s3/S3Storage.java