Check if the delayed operation is already completed
Check if the delayed operation is already completed
Upon completion, return the current response status along with the error code per partition
Upon completion, return the current response status along with the error code per partition
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 delayed produce operation can be completed if every partition it produces to is satisfied by one of the following:
The delayed produce operation can be completed if every partition it produces to is satisfied by one of the following:
Case A: This broker is no longer the leader: set an error in response Case B: This broker is the leader: B.1 - If there was a local error thrown while checking if at least requiredAcks replicas have caught up to this operation: set an error in response B.2 - Otherwise, set the response with no error.
A delayed produce operation that can be created by the replica manager and watched in the produce operation purgatory