You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/12/21 12:30:58 UTC
[jira] [Commented] (KAFKA-4426) Add consumer.close(timeout, unit)
for graceful close with timeout
[ https://issues.apache.org/jira/browse/KAFKA-4426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15766945#comment-15766945 ]
ASF GitHub Bot commented on KAFKA-4426:
---------------------------------------
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/2285
KAFKA-4426: Add close with timeout for KafkaConsumer
Code corresponding to KIP-102.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka KAFKA-4426
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/2285.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2285
----
commit 2945ad36d33cd6c586f4260da2fa9b0324d31ed4
Author: Rajini Sivaram <ra...@googlemail.com>
Date: 2016-11-22T14:19:46Z
KAFKA-4426: Add close with timeout for KafkaConsumer
----
> Add consumer.close(timeout, unit) for graceful close with timeout
> -----------------------------------------------------------------
>
> Key: KAFKA-4426
> URL: https://issues.apache.org/jira/browse/KAFKA-4426
> Project: Kafka
> Issue Type: Improvement
> Components: consumer
> Affects Versions: 0.10.1.0
> Reporter: Rajini Sivaram
> Assignee: Rajini Sivaram
>
> KAFKA-3703 implements graceful close of consumers with a hard-coded timeout of 5 seconds. For consistency with the producer, add a close method with configurable timeout for Consumer.
> {quote}
> public void close(long timeout, TimeUnit unit);
> {quote}
> Since this is a public interface change, this change requires a KIP.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)