junrao commented on a change in pull request #8935:
URL: https://github.com/apache/kafka/pull/8935#discussion_r454484427
##########
File path: core/src/main/scala/kafka/controller/ControllerEventManager.scala
##########
@@ -139,4 +140,19 @@ class ControllerEventManager(controllerId: Int,
}
}
+ private def pollFromEventQueue(): QueuedEvent = {
Review comment:
What I was thinking is the following. We change Histogram so that it
tracks the last time it's updated. If the expiration time has been reached, the
histogram will reset on next update. If there is no next update, but the
histogram value is being read, we will also reset the value on read.
----------------------------------------------------------------
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
