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

Open

merlimat wants to merge 5 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