conduktor.io ↗

KIP-288 — [DISCARDED] Consumer.poll() timeout semantic change and new waitForAssignment method

Discarded Kafka 2.0 Consumer

Proposed changing `Consumer.poll(long timeout)` semantics so the timeout applies uniformly to all blocking operations within poll, and adding a `waitForAssignment()` method. The existing `poll()` timeout is inconsistently applied — some internal blocking calls (e.g., group coordinator lookup) can block indefinitely regardless of the timeout. (Discarded in favor of KIP-266.)

Details

AuthorJohn Roesler
StatusDiscarded
Kafka Version2.0
JIRAKAFKA-5697
WikiView on Apache Wiki
Created2018-04-17
Last Modified2018-04-17
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.