fix(storage): serve the write buffer on read so acked records are consumable (read-after-ack) - #149

Merged

novatechflow merged 5 commits into

KafScale:mainfrom

kamir:fix/broker-ack-but-lost-v1.6.0

Jul 7, 2026

Commits on Jul 7, 2026

test(storage): reproduce acks-but-unreadable (read-after-ack) data bug

Scalytics
authored and
novatechflow
committed
b0da209
fix(storage): serve the write buffer on read so acked records are consumable

Scalytics
authored and
novatechflow
committed
894b8fd
test(storage): multi-flush durability — all acked offsets readable across rotations

Scalytics
authored and
novatechflow
committed
a2105a0
fix(broker): advance the fetch high-watermark for the buffered tail in flush-disabled mode

authored and
novatechflow
committed
f86577f
fix: resolve -race CI flakes for PR #149
novatechflow
committed
5d2e21f