diff --git a/benchmark-framework/src/main/java/io/openmessaging/benchmark/WorkloadGenerator.java b/benchmark-framework/src/main/java/io/openmessaging/benchmark/WorkloadGenerator.java index dc91353ee..856524946 100644 --- a/benchmark-framework/src/main/java/io/openmessaging/benchmark/WorkloadGenerator.java +++ b/benchmark-framework/src/main/java/io/openmessaging/benchmark/WorkloadGenerator.java @@ -71,7 +71,11 @@ public TestResult run() throws Exception { Timer timer = new Timer(); List topics = worker.createTopics(new TopicsInfo(workload.topics, workload.partitionsPerTopic)); - log.info("Created {} topics in {} ms", topics.size(), timer.elapsedMillis()); + log.info( + "Created {} topics in {} ms, topics: [{}]", + topics.size(), + timer.elapsedMillis(), + String.join(",", topics)); createConsumers(topics); createProducers(topics);