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
| Author | A. Sophie Blee-Goldman |
| Status | Accepted |
| Kafka Version | 2.6 |
| JIRA | KAFKA-9525 |
| Wiki | View on Apache Wiki |
| Created | 2020-02-07 |
| Last Modified | 2020-04-30 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.