conduktor.io ↗

KIP-571 — Add option to force remove members in StreamsResetter

Accepted Kafka 2.6 StreamsAdmin

Adds a `--force-remove` option to the Kafka Streams application resetter tool that calls `AdminClient.removeMembersFromConsumerGroup` to evict all static and dynamic members from the consumer group. This unblocks application resets when leftover group members hold up the group coordinator past the session timeout, particularly when session.timeout.ms is configured to a high value.

Protocol Impact

LeaveGroup

Details

Authorfeyman
StatusAccepted
Kafka Version2.6
JIRAKAFKA-9146
WikiView on Apache Wiki
Created2020-02-13
Last Modified2020-05-29
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.