[ https://issues.apache.org/jira/browse/KAFKA-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14356344#comment-14356344 ]
Sriharsha Chintalapani commented on KAFKA-1461: ----------------------------------------------- [~junrao] [~guozhang] please take a look at the above patch . Let me know if that's what you have in mind. I also added "replica.fetch.backoff.ms" and "controller.socket.timeout.ms" to TestUtils.createBrokerConfig this reduced the total test run time from 15mins to under 10mins on my machine. > Replica fetcher thread does not implement any back-off behavior > --------------------------------------------------------------- > > Key: KAFKA-1461 > URL: https://issues.apache.org/jira/browse/KAFKA-1461 > Project: Kafka > Issue Type: Improvement > Components: replication > Affects Versions: 0.8.1.1 > Reporter: Sam Meder > Assignee: Sriharsha Chintalapani > Labels: newbie++ > Fix For: 0.8.3 > > Attachments: KAFKA-1461.patch, KAFKA-1461.patch > > > The current replica fetcher thread will retry in a tight loop if any error > occurs during the fetch call. For example, we've seen cases where the fetch > continuously throws a connection refused exception leading to several replica > fetcher threads that spin in a pretty tight loop. > To a much lesser degree this is also an issue in the consumer fetcher thread, > although the fact that erroring partitions are removed so a leader can be > re-discovered helps some. -- This message was sent by Atlassian JIRA (v6.3.4#6332)