private void waitTopicsReadyWithoutConsumer() {
        producerService.probe();
        try {
            // If there is no consumer, we can only wait for a fixed time to ensure the topic is ready.
            Thread.sleep(TimeUnit.SECONDS.toMillis(30));
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }
Partitions that are ready to be consumed.
Only used during the initial topic readiness check, which is, {@link #preparing} is true.
tools/src/main/java/org/apache/kafka/tools/automq/PerfCommand.java