conduktor.io ↗

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

AuthorRajini Sivaram
StatusAccepted
Kafka Version1.0
JIRAKAFKA-4426
WikiView on Apache Wiki
Created2016-12-15
Last Modified2017-01-10
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.