conduktor.io ↗

KIP-211 — Revise Expiration Semantics of Consumer Group Offsets

Accepted Kafka 2.1 Consumer

Changes offset expiration semantics so that committed offsets for a consumer group are only expired after both `offsets.retention.minutes` has elapsed since the last commit AND the consumer group itself is empty (no active members). Under the old semantics, offsets for inactive partitions within an otherwise active group expired on their own schedule, causing active consumers to lose their committed position and reset to `auto.offset.reset`.

Details

AuthorVahid Hashemian
StatusAccepted
Kafka Version2.1
JIRAKAFKA-4682
WikiView on Apache Wiki
Created2017-10-18
Last Modified2019-05-14
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.