Skip to content

Commit

Permalink
refactor: add topic names when logging topics created
Browse files Browse the repository at this point in the history
Usability fix to know which topics are created during benchmark setup.
This helps when running multiple benchmarks and want to look metrics for specific topics.
  • Loading branch information
jeqo committed Jun 28, 2024
1 parent c361cbc commit f40c3cc
Showing 1 changed file with 5 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,11 @@ public TestResult run() throws Exception {
Timer timer = new Timer();
List<String> 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);
Expand Down

0 comments on commit f40c3cc

Please sign in to comment.