Table of Contents |
---|
Status
Current state: VotingUnder Discuss
JIRA: here
Pull Request: here
...
The semantics of "auto.offset.reset" remain unchanged. In order to describe in more detail what these parameters mean, and how they behave in various situations. We decide two categories where need reset offset.
"auto.offset.reset.on.no.initial.offset" (When the group starts consumption for the first time, the offset needs to be initialized):
initial offset reset strategy | proposed reset behavior when set initial offset |
none | fall back to *auto.offset.reset*: if none, throw exception |
earliest_on_start | reset to earliest |
latest_on_start | reset to latest |
...
"auto.offset.reset.on.invalid.offset" (When out of range or other abnormal offset inconsistencies occur during consumption):
invalid offset reset strategy | proposed reset behavior when trigger out of range |
none | fall back to *auto.offset.reset*: if none, throw exception |
nearest | to the earliest if it was under the range, or to the latest if it was over the range. |
...