conduktor.io ↗

KIP-568 — Explicit rebalance triggering on the Consumer

Accepted Kafka 2.6 Consumer

Adds a `KafkaConsumer.enforceRebalance(reason)` method that forces the broker to trigger an immediate rebalance by sending a `JoinGroupRequest` with `generation=-1`. Kafka Streams required the ability to force immediate rebalances for its cooperative protocol (task warm-up transfers, version probing), but the only existing mechanism—unsubscribe then resubscribe—was asynchronous and unreliable.

Details

AuthorA. Sophie Blee-Goldman
StatusAccepted
Kafka Version2.6
JIRAKAFKA-9525
WikiView on Apache Wiki
Created2020-02-07
Last Modified2020-04-30
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.