[ https://issues.apache.org/jira/browse/KAFKA-3885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Manikumar resolved KAFKA-3885. ------------------------------ Resolution: Duplicate > Kafka new producer cannot failover > ---------------------------------- > > Key: KAFKA-3885 > URL: https://issues.apache.org/jira/browse/KAFKA-3885 > Project: Kafka > Issue Type: Bug > Components: clients > Affects Versions: 0.8.2.2, 0.9.0.0, 0.9.0.1, 0.10.0.0 > Reporter: wateray > > This bug can reproduce by the following steps. > The cluster has 2 brokers. > a) start a new producer, then send messages, it works well. > b) Then kill one broker, it works well. > c) Then restart the broker, it works well. > d) Then kill the other broker, the producer can't failover. > The the producer print log infinity. > org.apache.kafka.common.errors.TimeoutException: Batch containing 1 record(s) > expired due to timeout while requesting metadata from brokers for > lwb_test_p50_r2-29 > ================ > When producer sends msg, it detected that metadata should update. > But at this code, class: NetworkClient ,method: leastLoadedNode > List<Node> nodes = this.metadataUpdater.fetchNodes(); > nodes only return one result, and the returned node is the killed node, so > the producer cannot failover! -- This message was sent by Atlassian JIRA (v6.4.14#64029)