kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Andrew Stein (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.
Date Wed, 01 Oct 2014 13:54:34 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14154809#comment-14154809
] 

Andrew Stein commented on KAFKA-1660:
-------------------------------------

Hi [~jkreps],

I don't think that this (the request for {{producer.close(timeout)}}) and KAFKA-1659 (the
request for {{producer.abort()}}) are the same.
 
If {{producer.close(timeout)}} were to return without actually closing the producer in time,
the user could then continue with {{producer.abort()}}. However, this would not be the only
case where {{producer.abort()}} would be useful. It could be used if a {{producer.send()}}
were to fail or if a {{future.get()}} were to fail as well.

In addition if {{producer.close()}} were to return without actually closing the producer in
time, the user could continue with other logic besides {{producer.abort()}}.


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

Mime
View raw message