consumer_offsets


Description

{“what”:“Tracks the last consumed message offset per device for a queue.”,“why”:“Without it, a device restart would re-read old messages or skip new ones.”,“by”:“fleet-annotator-worker”,“at”:“2026-09-23T00:11:39.296633216+00:00”}

Columns

Column Type Size Nulls Auto Default Children Parents Comments
device text 2147483647 null

{“what”:“Unique device identifier; primary key for the offset record.”,“why”:“Identifies which device’s consumption progress this row tracks.”,“by”:“fleet-annotator-worker”,“at”:“2026-09-23T00:11:39.346966358+00:00”}

last_offset int8 19 0

{“what”:“Last message offset consumed by the device; starts at 0.”,“why”:“Enables resuming consumption from the correct position after a restart.”,“by”:“fleet-annotator-worker”,“at”:“2026-09-23T00:11:39.376232275+00:00”}

updated_at text 2147483647 null

{“what”:“Timestamp of the last offset update, stored as text (e.g., ISO 8601).”,“why”:“Shows how recent the offset is; helps detect stale or inactive devices.”,“by”:“fleet-annotator-worker”,“at”:“2026-09-23T00:11:39.430598899+00:00”}

Indexes

Constraint Name Type Sort Column(s)
consumer_offsets_pkey Primary key Asc device

Relationships