diff --git a/internal/syncer/syncer.go b/internal/syncer/syncer.go index 98ad747..858083d 100644 --- a/internal/syncer/syncer.go +++ b/internal/syncer/syncer.go @@ -74,7 +74,7 @@ func (s *Syncer) Process(ctx context.Context) error { kvRows, err := pgx.CollectRows(rows, func(row pgx.CollectableRow) (KVRow, error) { var kvRow KVRow - err := row.Scan(&kvRow.Key, &kvRow.Value, &kvRow.Updated) + err := row.Scan(&kvRow.ID, &kvRow.Key, &kvRow.Value, &kvRow.Updated) return kvRow, err }) if err != nil {