[ https://issues.apache.org/jira/browse/KAFKA-1260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jay Kreps updated KAFKA-1260: ----------------------------- Attachment: KAFKA-1260-fix.patch Hey Guozhang, this patch fixes two issues that effected that test. Essentially the problem was I was only moving nodes into the "disconnected" state if I had outstanding requests in flight which is clearly a logical bug. Now both of your unit tests seem to pass for me. > Integration Test for New Producer Part II: Broker Failure Handling > ------------------------------------------------------------------ > > Key: KAFKA-1260 > URL: https://issues.apache.org/jira/browse/KAFKA-1260 > Project: Kafka > Issue Type: Sub-task > Components: producer > Reporter: Guozhang Wang > Assignee: Guozhang Wang > Attachments: KAFKA-1260-fix.patch, KAFKA-1260.patch, > KAFKA-1260_2014-02-13_15:14:21.patch, KAFKA-1260_2014-02-14_15:00:16.patch, > KAFKA-1260_2014-02-19_13:49:19.patch, KAFKA-1260_2014-02-19_15:55:06.patch > > -- This message was sent by Atlassian JIRA (v6.1.5#6160)