Description
Currently, the ReplicaManager.delayedFetchPurgatory is only completed when appending as leader. With https://cwiki.apache.org/confluence/display/KAFKA/KIP-392%3A+Allow+consumers+to+fetch+from+closest+replica enabled, followers will also have to complete delayed fetch requests after successfully replicating. Otherwise, consumer fetches to closest followers will hit fetch.max.wait.ms
Attachments
Issue Links
- links to