adixitconfluent opened a new pull request, #16969: URL: https://github.com/apache/kafka/pull/16969
### About Introduced a share fetch purgatory on the broker which delays share fetch requests that cannot be completed instantaneously. Introduced 2 new classes - 1. **DelayedShareFetch** - Contains logic to instantaneously complete or force complete a share fetch request on timeout. 2. **DelayedShareFetchKey** - Contains the key which can be used to watch the entries within the share fetch purgatory. The SharePartitionManager code for fetching from ReplicaManager has been refactored to DelayedShareFetch class and appropriate changes to handling the fetch queue locks have been made. ### Testing The code has been tested with the help of unit tests. -- 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
