jiameixie commented on a change in pull request #8836:
URL: https://github.com/apache/kafka/pull/8836#discussion_r599267296
##########
File path: core/src/main/scala/kafka/tools/ConsumerPerformance.scala
##########
@@ -105,16 +105,14 @@ object ConsumerPerformance extends LazyLogging {
var messagesRead = 0L
var lastBytesRead = 0L
var lastMessagesRead = 0L
- var joinStart = 0L
var joinTimeMsInSingleRound = 0L
consumer.subscribe(topics.asJava, new ConsumerRebalanceListener {
def onPartitionsAssigned(partitions: util.Collection[TopicPartition]):
Unit = {
- joinTime.addAndGet(System.currentTimeMillis - joinStart)
Review comment:
@guozhangwang Sorry for my late reply. I am not working on this PR.
Should I abandon this PR? So other people can work on this issue.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
