[jira] [Created] (KAFKA-4426) Add consumer.close(timeout, unit) for graceful close with timeout

[Rajini Sivaram (JIRA)]

Rajini Sivaram created KAFKA-4426:
-------------------------------------

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