Guozhang Wang created KAFKA-1629:
------------------------------------

             Summary: Replica fetcher thread need to back off upon getting 
errors on partitions
                 Key: KAFKA-1629
                 URL: https://issues.apache.org/jira/browse/KAFKA-1629
             Project: Kafka
          Issue Type: Bug
            Reporter: Guozhang Wang
             Fix For: 0.9.0


ReplicaFetcherThread's handlePartitionsWithErrors() function needs to be 
implemented (currently it is an empty function) such that upon getting errors 
on these partitions, the fetcher thread will back off the corresponding simple 
consumer to retry fetching that partition.

This can happen when there is leader migration, the replica may get a bit 
delayed receiving the leader ISR update request before keeping retry fetching 
the old leader.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to