private static long toBps(long kbps) {
        return kbps << 10;
    }
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