private Lock getStreamCallbackLock(long streamId) {
        return streamCallbackLocks[(int) ((streamId & Long.MAX_VALUE) % NUM_STREAM_CALLBACK_LOCKS)];
    }
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