[jira] [Created] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[Andrew Stein (JIRA)]

Andrew Stein created KAFKA-1660:
-----------------------------------

             Summary: 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
            Reporter: Andrew Stein
            Assignee: Jun Rao
             Fix For: 0.8.2


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)