[KAFKA-18014] Add duration based offset reset option for ShareConsumer

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 4.0.0
• Assignee: Peter Lee
• Reporter: Manikumar
• Created: 14/Nov/24 13:36
• Updated: 16/Dec/24 08:27
• Resolved: 16/Dec/24 08:27

Description

Kafka consumer supports auto.offset.reset config option, which is used when there is no initial offset in Kafka (or) if the current offset does not exist any more on the server. This config currently supports earliest/latest/none options. Currently consumer resets might force applications to reprocess large amounts of data from earlier offsets. With infinite storage, its beneficial to have a duration based offset reset strategy. This will allow applications to consume/initialise from a fixed duration when there is no initial offset in Kafka.

As part of KIP-932, we are adding support for share consumer groups. Share consumer groups supports dynamic group configuration property share.auto.offset.reset. This is used to set the initial Share-Partition Start Offset (SPSO) based on the share.auto.offset.reset configuration. Currently share.auto.offset.reset supports earliest and latest options to automatically reset the offset

Similar to the Kafka Consumer, we will add support for by_duration: config value for share.auto.offset.reset.

from KIP-1106

Issue Links

• supercedes: KAFKA-18121 Add support for duration-based offset reset strategy
• links to: GitHub Pull Request #18040
• links to: GitHub Pull Request #18096