adixitconfluent opened a new pull request, #19757: URL: https://github.com/apache/kafka/pull/19757
### About Consumer groups have a different timeout `REMOTE_FETCH_MAX_WAIT_MS_PROP` in delayed fetch purgatory for fetch requests having remote storage fetch ([code link](https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/server/ReplicaManager.scala#L1669)). This is done before the request enters the purgatory, so its easy to change. At the moment share groups can only have a `waitTimeMs` `of shareFetch.fetchParams().maxWaitMs` (default value `500ms`) for delayed share fetch purgatory regardless of whether they are remote storage/local log fetch. This PR introduces a way to increase the timeout of remote storage fetch requests if a remote storage fetch request couldn't complete within `shareFetch.fetchParams().maxWaitMs`, then we create a timer task which can be interrupted whenever `pendingFetches` is finished. The change has been done to avoid the expiration of remote storage share fetch requests. ### 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
