[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14351179#comment-14351179 ]
Parth Brahmbhatt commented on KAFKA-1660: ----------------------------------------- No and I wont be able to do it for probably next couple of weeks. If this is a pressing issue and someone else wants to take over the jira, please feel free to do so. > Ability to call close() with a timeout on the Java Kafka Producer. > ------------------------------------------------------------------- > > Key: KAFKA-1660 > URL: https://issues.apache.org/jira/browse/KAFKA-1660 > Project: Kafka > Issue Type: Improvement > Components: clients, producer > Affects Versions: 0.8.2.0 > Reporter: Andrew Stein > Assignee: Parth Brahmbhatt > Fix For: 0.8.3 > > Attachments: KAFKA-1660.patch, KAFKA-1660_2015-02-17_16:41:19.patch, > KAFKA-1660_2015-03-02_10:41:49.patch > > > I would like the ability to call {{close}} with a timeout on the Java > Client's KafkaProducer. > h6. Workaround > Currently, it is possible to ensure that {{close}} will return quickly by > first doing a {{future.get(timeout)}} on the last future produced on each > partition, but this means that the user has to define the partitions up front > at the time of {{send}} and track the returned {{future}}'s -- This message was sent by Atlassian JIRA (v6.3.4#6332)