conduktor.io ↗

KIP-842 — Add richer group offset reset mechanisms

Discussion Consumer

Extends group offset reset with richer InitialOffsetResetStrategy options (e.g., EARLIEST_LOCAL, BY_DURATION) to handle scenarios such as consumer groups encountering newly added partitions after a topic partition count increase. The default auto.offset.reset=latest causes newly added partitions to start at the latest offset, silently skipping data that was produced into those partitions before the consumer group's rebalance detected the new partition count.

Details

Authorhudeqi
StatusDiscussion
JIRAKAFKA-12478
WikiView on Apache Wiki
Created2022-05-23
Last Modified2024-05-31
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.