[ 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)