Poll flow using acks sent received from the app thread#5339

Draft

Pranav Rathi (pranavrth) wants to merge 43 commits intodev_kip-932_queues-for-kafkafrom

dev_kip-932_poll-using-ack-mapping

Commits on Jan 9, 2026

Prototype code to obtain assignments

Milind L (milindl)
authored and
Pranav Rathi (pranavrth)
committed
Implement polling logic to work with normal fetch

Milind L (milindl)
authored and
Pranav Rathi (pranavrth)
committed
Call sharegroupheartbeat when leaving group (#5247)

Pratyush Ranjan (PratRanj07)
authored and
Pranav Rathi (pranavrth)
committed
Add SHARE_FETCH op handling in broker thread
Pranav Rathi (pranavrth)
committed
Add session epoch and partition management
Pranav Rathi (pranavrth)
committed
Improve refcount debugging for toppar destroy
Pranav Rathi (pranavrth)
committed
Add session leave while decommissioning the broker.
Pranav Rathi (pranavrth)
committed
Implicitly acknowledge all batches instead of just the first batch which was done just to make initial basic share fetch work.
Pranav Rathi (pranavrth)
committed
* Create a new type for share consumer
Pranav Rathi (pranavrth)
committed
Fix UNKNOWN_ERROR from broker arising because broker was not accepting Uuid without url encoing. Fix by explicitly doing url encoding for the generated Uuid. Should be fixed on the broker side and …
Pranav Rathi (pranavrth)
committed

Commits on Feb 13, 2026

ShareGroupHeartBeat API (#5299)
Ankith L (Ankith-Confluent)
authored

Commits on Feb 15, 2026

MockBroker: Implement ShareFetch API (#5302)

Kaushik Raina (k-raina)
and
Ankith L (Ankith-Confluent)
authored

Commits on Feb 20, 2026

Commits on Feb 23, 2026

Commits on Feb 24, 2026

Commits on Mar 2, 2026