You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/02/19 07:05:00 UTC
[jira] [Created] (KAFKA-6571) KafkaProducer.close(0) should be
non-blocking
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)