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

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.10.1.0
• Fix Version/s: 0.10.2.0
• Component/s: consumer
• Assignee: Rajini Sivaram
• Reporter: Rajini Sivaram
• Reviewer: Jason Gustafson
• Created: 21/Nov/16 09:40
• Updated: 24/Jan/17 07:33
• Resolved: 12/Jan/17 00:15

Description

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.

public void close(long timeout, TimeUnit unit);

Since this is a public interface change, this change requires a KIP.

Issue Links

• duplicates: KAFKA-3540 KafkaConsumer.close() may block indefinitely
• links to: GitHub Pull Request #2285
• mentioned in: Page Loading...