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
