KIP-102 — Add close with timeout for consumers
Accepted Kafka 1.0 Consumer
Adds a close(long timeout, TimeUnit unit) overload to the Consumer interface, giving callers a bounded shutdown window during which pending commits and group leave requests are attempted before forcible closure. The existing close() had a hard-coded 5-second graceful shutdown timeout with no way for callers to extend or reduce it, creating symmetry issues with the producer's two-variant close API.
Details
| Author | Rajini Sivaram |
| Status | Accepted |
| Kafka Version | 1.0 |
| JIRA | KAFKA-4426 |
| Wiki | View on Apache Wiki |
| Created | 2016-12-15 |
| Last Modified | 2017-01-10 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.