[
https://issues.apache.org/jira/browse/KAFKA-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16576931#comment-16576931
]
Ahmed Al-Mehdi edited comment on KAFKA-6571 at 8/10/18 10:35 PM:
-----------------------------------------------------------------
After discussion with [~lindong], assigning bug to self.
was (Author: ahmeda):
After discussion with Dong, assigning bug to self.
> 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: Ahmed Al-Mehdi
> Priority: Major
>
> 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)
