Repository navigation

fix(fetch): bound each partition's read so one slow partition can't starve the rest - #852

Open

solace-aross wants to merge 10 commits into

mainfrom

fix/sol-155330-fetch-partition-starvation

Commits on Oct 9, 2026
- fix(fetch): bound each partition's read so one slow partition can't starve the rest
  
  solace-aross
  and
  claude
  committed
  9d43465
- docs: capitalize three comment sentences in fetch.rs
  
  solace-aross
  and
  claude
  committed
  3c3de1e
- fix(fetch): end each storage budget inside its partition's share
  
  solace-aross
  and
  claude
  committed
  ac6446f
- fix(fetch): count abandoned reads by storage operation and stage, and log the offset
  
  solace-aross
  and
  claude
  committed
  8763ae6
- test(fetch): pin both budget margin rules and the offset stage stalls
  
  solace-aross
  and
  claude
  committed
  e196106
- test(fetch): the storage budget starts once the offset stage is read
  
  solace-aross
  and
  claude
  committed
  9996a14
- fix(storage): charge the permit wait to the budget in SemaphoreProxy::fetch
  
  solace-aross
  and
  claude
  committed
  eabbed0
- docs: say what a Fetch partition answers and logs at each deadline stage
  solace-aross
  committed
  b23c5e2
- docs(fetch): state what each engine reads with no budget and where an unread partition counts
  
  solace-aross
  and
  claude
  committed
  7f980b2
- test(fetch): pin the raised last stable offset under ReadCommitted
  
  solace-aross
  and
  claude
  committed
  444365b