Update pull-based ingestion multi-threaded writer flow batchStartPointer computation#21697

Merged

varunbharadwaj merged 3 commits into

opensearch-project:mainfrom

varunbharadwaj:vb/fixmultipartition

May 21, 2026

Commits on May 20, 2026

handle multi partition first message race condition
varunbharadwaj
committed
synchronize kafka consumer to prevent concurrent access
varunbharadwaj
committed
add comments explaining fallback to first queued pointer logic
varunbharadwaj
committed