Kamal Chandraprakash

KAFKA-15776: Use the FETCH request timeout as the delay timeout for DelayedRemoteFetch

4

DelayedRemoteFetch uses `fetch.max.wait.ms` config as a delay timeout for DelayedRemoteFetchPurgatory. `fetch.max.wait.ms` purpose is to wait for the given amount of time when there is no data available to serve the...

KAFKA-15859: Make RemoteListOffsets call an async operation

6

This is the part-2 of the [KIP-1075](https://cwiki.apache.org/confluence/display/KAFKA/KIP-1075%3A+Introduce+delayed+remote+list+offsets+purgatory+to+make+LIST_OFFSETS+async) To find the offset for a given timestamp, ListOffsets API is used by the client. When the topic is enabled with remote storage,...

This is the part-1 of the [KIP-1075](https://cwiki.apache.org/confluence/display/KAFKA/KIP-1075%3A+Introduce+delayed+remote+list+offsets+purgatory+to+make+LIST_OFFSETS+async) ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build...