Check if the delayed operation is already completed
Check if the delayed operation is already completed
Upon completion, read whatever data is available and pass to the complete callback
Upon completion, read whatever data is available and pass to the complete callback
Call-back to execute when a delayed operation gets expired and hence forced to complete.
Call-back to execute when a delayed operation gets expired and hence forced to complete.
The operation can be completed if:
The operation can be completed if:
Case A: This broker is no longer the leader for some partitions it tries to fetch Case B: This broker does not know of some partitions it tries to fetch Case C: The fetch offset locates not on the last segment of the log Case D: The accumulated bytes from all the fetching partitions exceeds the minimum bytes
Upon completion, should return whatever data is available for each valid partition
A delayed fetch operation that can be created by the replica manager and watched in the fetch operation purgatory