Skip to content
2 changes: 1 addition & 1 deletion faust/tables/recovery.py
Original file line number Diff line number Diff line change
Expand Up @@ -706,7 +706,7 @@ async def _build_offsets(
earliest = await consumer.earliest_offsets(*tps)
# FIXME To be consistent with the offset -1 logic
earliest = {
tp: offset - 1 if offset is not None else None
tp: offset if offset is not None else None
for tp, offset in earliest.items()
}

Expand Down