private BlockingBucket rateLimitBucket(int rateLimit) {
        return Bucket.builder()
            .addLimit(limit -> limit
                .capacity(rateLimit / 10)
                .refillGreedy(rateLimit, Duration.ofSeconds(1))
            ).build()
            .asBlocking();
    }
Reset all consumer offsets (100% consumers)
@param startMillis    The timestamp to start seeking from
@param intervalMillis The interval between group starts
tools/src/main/java/org/apache/kafka/tools/automq/perf/ConsumerService.java