[ https://issues.apache.org/jira/browse/KAFKA-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ahmed Al-Mehdi reassigned KAFKA-6571: ------------------------------------- Assignee: Ahmed Al-Mehdi (was: Dong Lin) > 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)