Jiangjie Qin created KAFKA-2277: ----------------------------------- Summary: New producer treats requests to a disconnected broker as acks=0. Key: KAFKA-2277 URL: https://issues.apache.org/jira/browse/KAFKA-2277 Project: Kafka Issue Type: Bug Reporter: Jiangjie Qin Assignee: Jiangjie Qin Priority: Blocker
What happened is as below: 1. When Selector detected a disconnected node. It adds the node to disconnected set. 2. NetworkClient.handleDisconnections() will add a response with null body in to response list. 3. Sender.handleProduceResponse() treat empty response body as acks=0. Messages are completed without being sent out. -- This message was sent by Atlassian JIRA (v6.3.4#6332)