Dong Lin created KAFKA-6571:
-------------------------------
Summary: KafkaProducer.close(0) should be non-blocking
Key: KAFKA-6571
URL: https://issues.apache.org/jira/browse/KAFKA-6571
Project: Kafka
Issue Type: Bug
Reporter: Dong Lin
Assignee: Dong Lin
According to the Java doc of producer.close(long timeout, TimeUnit timeUnit),
it is said that "Specifying a timeout of zero means do not wait for pending
send requests to complete". However, producer.close(0) can currently block on
waiting for the sender thread to exit, which in turn can block on user's
callback.
We probably should not let producer.close(0) join the sender thread if user has
specified zero timeout.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
