Rajini Sivaram created KAFKA-3703: ------------------------------------- Summary: PlaintextTransportLayer.close() doesn't complete outgoing writes Key: KAFKA-3703 URL: https://issues.apache.org/jira/browse/KAFKA-3703 Project: Kafka Issue Type: Bug Reporter: Rajini Sivaram Assignee: Rajini Sivaram
Outgoing writes may be discarded when a connection is closed. For instance, when running a producer with acks=0, a producer that writes data and closes the producer would expect to see all writes to complete if there are no errors. But close() simply closes the channel and socket which could result in outgoing data being discarded. -- This message was sent by Atlassian JIRA (v6.3.4#6332)