Skip to main content

Module offsets

Module offsets 

Source
Expand description

Kafka offset tracking for per-partition consumption progress.

OffsetTracker maintains the latest consumed offset for each topic-partition and supports checkpoint/restore roundtrips via SourceCheckpoint.

Structsยง

OffsetTracker
Tracks consumed offsets per topic-partition.