diff --git a/tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java b/tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java index f4a987e77d501..5aa943a41c521 100644 --- a/tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java +++ b/tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java @@ -115,7 +115,7 @@ static void run(String[] args, Function> co } protected static void printHeader(boolean showDetailedStats) { - String newFieldsInHeader = ", rebalance.time.ms, fetch.time.ms, fetch.MB.sec, fetch.nMsg.sec"; + String newFieldsInHeader = ", stop.the.world.ms, fetch.time.ms, fetch.MB.sec, fetch.nMsg.sec"; if (!showDetailedStats) System.out.printf("start.time, end.time, data.consumed.in.MB, MB.sec, data.consumed.in.nMsg, nMsg.sec%s%n", newFieldsInHeader); else