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
| Author | hudeqi |
| Status | Discussion |
| JIRA | KAFKA-12478 |
| Wiki | View on Apache Wiki |
| Created | 2022-05-23 |
| Last Modified | 2024-05-31 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.