First line of detailed stats from consumer-perf-test.sh incorrect
@@ -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 {
