apoorvmittal10 opened a new pull request, #15234: URL: https://github.com/apache/kafka/pull/15234
KIP-714 requires client instance cache in broker which should also have a time-based eviction policy where client instances which are not actively sending metrics should be evicted. KIP mentions `This client instance specific state is maintained in broker memory up to MAX(60*1000, PushIntervalMs * 3) milliseconds` The PR adds support to evict such instances from the cache. There could be multiple approaches for the eviction i.e. 1. Periodically iterating on all entries in the cache as every instance can have different TTL (based on configured push interval) 2. Using heap to store instance eviction - using delay queues 3. Using hashed wheel timer which updates and evicts entries in O(1) time (minor overhead of bucketed delay queues) I have also moved a wrapper class for SystemTimer from `grou-coordinator` to `utils`. cc: @AndrewJSchofield @junrao ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) -- 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. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
