jiameixie commented on pull request #8836:
URL: https://github.com/apache/kafka/pull/8836#issuecomment-643961078


   > In the new code we may not trigger `onPartitionsRevoked` anymore although 
`onPartitionsAssigned` is always triggered, so we can no longer rely on them to 
measure the latency. I'm actually thinking we can just get the rebalance 
latency from metrics directly --- KafkaConsumer.metrics() exposed them --- you 
can find more details of the added metrics in KIP-429.
   
   @chia7712 @guozhangwang I updated the code which using 
KafkaConsumer.metrics() to get rebalance time.  Could you please review it?


----------------------------------------------------------------
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


Reply via email to