Per-doc aggregates must use version 1 (not i+1 / 99) or ClaimLeases skips them under event_consumer_checkpoints head+1 gating.
Per-doc aggregates must use version 1 (not i+1 / 99) or ClaimLeases skips them under event_consumer_checkpoints head+1 gating.