Scalable Topics: `pulsar::st` queue consumer — per-segment fan-in over a mux receive queue - #605

Merged

merlimat merged 14 commits into

apache:mainfrom

merlimat:scalable-topics-queue-consumer

Aug 29, 2026

Commits on Jul 16, 2026

st: received-message plumbing — MessageImpl + MessageCore accessors
merlimat
committed
779e2cf
st: classic consumer segment seam — subscribeSegmentAsync
merlimat
committed
b0c7d11
st: clang-format-11 line wrapping in segment seam + MessageImpl ctor
merlimat
committed
f4f9ff5
st: queue consumer core — per-segment fan-in over a mux receive queue
merlimat
committed
e110361
Handle CommandReachedEndOfTopic on the consumer receive path
merlimat
committed
6b3285e
st: queue consumer produce->consume e2e test
merlimat
committed
7475790

Commits on Jul 20, 2026

Commits on Aug 28, 2026

Commits on Aug 29, 2026

Merge remote-tracking branch 'apache/main' into scalable-topics-queue-consumer
merlimat
committed
740b050