Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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 strategyproposed reset behavior when set initial offset
none

fall back to *auto.offset.reset*:

if none, throw exception
if earliest, reset to earliest
if latest, reset to latest

earliest_on_startreset to earliest
latest_on_startreset to latest

...

"auto.offset.reset.on.invalid.offset" (When out of range or other abnormal offset inconsistencies occur during consumption):

invalid offset reset strategyproposed reset behavior when trigger out of range
none

fall back to *auto.offset.reset*:

if none, throw exception
if earliest, reset to earliest
if latest, reset to latest

nearestto the earliest if it was under the range, or to the latest if it was over the range.

...