You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
The use case is always consuming the topic from beginning (to read the whole topic) or from the end (you only care about new messages), regardless of what the committed offsets were. See more info in #119
To support both cases we can add a config option begin_offset with the values :assigned and :reset and the following behaviour.
offset_reset_policy
begin_offset
outcome
:earliest
:reset
always read from start
:latest
:reset
always read from end
:earliest
:assigned
read from committed offset, or from start if not defined or expired (current behaviour)
:latest
:assigned
read from committed offset, or from end if not defined or expired (current behaviour)
The text was updated successfully, but these errors were encountered:
danmarcab
pushed a commit
to danmarcab/broadway_kafka
that referenced
this issue
Aug 25, 2023
The use case is always consuming the topic from beginning (to read the whole topic) or from the end (you only care about new messages), regardless of what the committed offsets were. See more info in #119
To support both cases we can add a config option
begin_offset
with the values:assigned
and:reset
and the following behaviour.:earliest
:reset
:latest
:reset
:earliest
:assigned
:latest
:assigned
The text was updated successfully, but these errors were encountered: