fix(streaming): prevent checkpoint gaps causing replay#10096

Merged

ReubenBond merged 18 commits into

dotnet:mainfrom

fickleEfrit:fix/streaming-checkpoint-flush

Jun 11, 2026

Commits on Jun 11, 2026

Fix streaming checkpoint gaps causing message replay on restart

authored and
ReubenBond
committed
Fix EventHub checkpoint watermark tracking

ReubenBond
and
Copilot
committed
Simplify checkpoint to periodic scan of pulling agent state

authored and
ReubenBond
committed
fix(streaming): report earliest delivery progress token

ReubenBond
and
Copilot
committed
fix(streaming): skip progress updates during registration

ReubenBond
and
Copilot
committed
fix(streaming): make checkpoint flush cancellable

ReubenBond
and
Copilot
committed
fix(streaming): block progress for pending consumers

ReubenBond
and
Copilot
committed
test(streaming): cover eventhub checkpoint rewinds

ReubenBond
and
Copilot
committed
fix(streaming): lazily evaluate checkpoint progress

ReubenBond
and
Copilot
committed
fix(streaming): keep checkpoints monotonic

ReubenBond
and
Copilot
committed
fix(streaming): simplify delivery progress updates

ReubenBond
and
Copilot
committed
fix(streaming): harden checkpoint progress updates

ReubenBond
and
Copilot
committed
refactor(streaming): remove eventhub purge checkpoint wrapper

ReubenBond
and
Copilot
committed
refactor(streaming): simplify checkpoint progress updates

ReubenBond
and
Copilot
committed
refactor(streaming): simplify eventhub checkpoint saves

ReubenBond
and
Copilot
committed
refactor(streaming): simplify stream group processing

ReubenBond
and
Copilot
committed
refactor(streaming): avoid throttling unchanged checkpoints

ReubenBond
and
Copilot
committed
fix(streaming): align rebased instrumentation wiring

ReubenBond
and
Copilot
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

fix(streaming): prevent checkpoint gaps causing replay#10096

fix(streaming): prevent checkpoint gaps causing replay#10096
ReubenBond merged 18 commits into
dotnet:mainfrom
fickleEfrit:fix/streaming-checkpoint-flush

Commits on Jun 11, 2026

Fix streaming checkpoint gaps causing message replay on restart

Fix EventHub checkpoint watermark tracking

Simplify checkpoint to periodic scan of pulling agent state

fix(streaming): report earliest delivery progress token

fix(streaming): skip progress updates during registration

fix(streaming): make checkpoint flush cancellable

fix(streaming): block progress for pending consumers

test(streaming): cover eventhub checkpoint rewinds

fix(streaming): lazily evaluate checkpoint progress

fix(streaming): keep checkpoints monotonic

fix(streaming): simplify delivery progress updates

fix(streaming): harden checkpoint progress updates

refactor(streaming): remove eventhub purge checkpoint wrapper

refactor(streaming): simplify checkpoint progress updates

refactor(streaming): simplify eventhub checkpoint saves

refactor(streaming): simplify stream group processing

refactor(streaming): avoid throttling unchanged checkpoints

fix(streaming): align rebased instrumentation wiring