You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Parth Brahmbhatt (JIRA)" <ji...@apache.org> on 2014/12/29 23:52:14 UTC
[jira] [Commented] (KAFKA-1660) Ability to call close() with a
timeout on the Java Kafka Producer.
[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14260510#comment-14260510 ]
Parth Brahmbhatt commented on KAFKA-1660:
-----------------------------------------
Created reviewboard https://reviews.apache.org/r/29467/diff/
against branch trunk
> 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.3
>
> Attachments: KAFKA-1660.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)