[ 
https://issues.apache.org/jira/browse/KAFKA-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16576931#comment-16576931
 ] 

Ahmed Al-Mehdi commented on KAFKA-6571:
---------------------------------------

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: Dong Lin
>            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)

Reply via email to