From 7ceb34bbeccab1d16def1812aecd61a6a3f021e0 Mon Sep 17 00:00:00 2001 From: Liju John Date: Thu, 19 Nov 2020 19:48:04 +0530 Subject: [PATCH] KAFKA-10701 First line of detailed stats from consumer-perf-test.sh incorrect (#9598) --- core/src/main/scala/kafka/tools/ConsumerPerformance.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/tools/ConsumerPerformance.scala b/core/src/main/scala/kafka/tools/ConsumerPerformance.scala index a329b4aae55..44324e898c3 100644 --- a/core/src/main/scala/kafka/tools/ConsumerPerformance.scala +++ b/core/src/main/scala/kafka/tools/ConsumerPerformance.scala @@ -106,7 +106,7 @@ object ConsumerPerformance extends LazyLogging { var messagesRead = 0L var lastBytesRead = 0L var lastMessagesRead = 0L - var joinStart = 0L + var joinStart = System.currentTimeMillis var joinTimeMsInSingleRound = 0L consumer.subscribe(topics.asJava, new ConsumerRebalanceListener {