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)