apoorvmittal10 opened a new pull request, #23892: URL: https://github.com/apache/kafka/pull/23892
On the slow path, `DelayedShareFetch.combineLogReadResponse` reuses the data read in `tryComplete` and issues a second `readFromLog` for partitions that became acquirable only at completion. The second read was issued even when the already fetched data covered `maxFetchRecords`, in which case `SharePartition.acquire` receives a zero budget and returns empty, so the read was wasted. The remaining record budget is now computed from the already fetched data and the second read is skipped when nothing remains. Skipped partitions are absent from the response, as share sessions already do for partitions without data, and their locks are released on the same path as before. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
