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)