Scalable Topics: `pulsar::st` stream consumer — controller-assigned ordered consumption with cumulative acks - #611

Open

merlimat wants to merge 7 commits into

apache:mainfrom

merlimat:scalable-topics-stream-consumer

Commits on Aug 31, 2026

st: consumer assignment session — controller registration for stream consumers
merlimat
committed
a5e2f12
st: stream consumer core — assignment-driven Exclusive fan-in with cumulative acks
merlimat
committed
0c13448
st: stream consumer e2e + shared admin harness for the e2e suites
merlimat
committed
749b037
st: clang-format-11 line wrapping in the stream consumer sources
merlimat
committed
b4609a1
st: pass promise and batch handles by const reference in the session and mux queue
merlimat
committed
5e9dfdf

Commits on Sep 1, 2026

st: fix stream consumer start ordering, close races and stale eviction
merlimat
committed
a15d0ed

Commits on Sep 2, 2026

st: drop the throwaway pre-subscription in the drain e2e
merlimat
committed
c38a5ec