Skip to content

Commit 2026e14

Browse files
Update tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java
Co-authored-by: refacto-visz[bot] <230139763+refacto-visz[bot]@users.noreply.github.com>
1 parent 7def5f4 commit 2026e14

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -125,7 +125,8 @@ record = new ProducerRecord<>(config.topicName, payload);
125125
/* print final results */
126126
stats.printTotal();
127127
/* print steady-state stats if relevant */
128-
if (steadyStateStats != null) {
128+
/* print steady-state stats if warmup was configured */
129+
if (config.warmupRecords > 0 && steadyStateStats != null) {
129130
steadyStateStats.printTotal();
130131
}
131132
} else {

0 commit comments

Comments
 (0)