private static long toKbps(long bps) {
        long kbps = bps >> 10;
        kbps = Math.min(kbps, MAX_BUCKET_TOKENS_PER_SECOND);
        kbps = Math.max(kbps, 1L);
        return kbps;
    }
Consume the specified number of bytes and return a CompletableFuture that will be completed when the
tokens are consumed.
Note: DO NOT perform any heavy operations in the callback, otherwise it will block the scheduler.
s3stream/src/main/java/com/automq/stream/s3/operator/TrafficRateLimiter.java