feat: support micro batching alternative at source#3450

Open

vaibhavtiwari33 wants to merge 15 commits into

mainfrom

Commits on Jun 2, 2026

feat: add Streaming *bool field to MonoVertexSpec
vaibhavtiwari33
committed
feat(validator): reject streaming=true with built-in Kafka source
vaibhavtiwari33
committed
feat: streaming MonoVertex source — continuous read and per-message ack
vaibhavtiwari33
committed
fix: acquire-after-read + inline dispatch for streaming source
vaibhavtiwari33
committed
feat: gate source-side batch metrics off under streaming
vaibhavtiwari33
committed
docs: streaming MonoVertex user-guide page with Kafka data-loss warning
vaibhavtiwari33
committed
test(e2e): streaming MonoVertex end-to-end test
vaibhavtiwari33
committed
feat: Update streaming documentation. Extract streaming source method. Implement watermark handling
vaibhavtiwari33
committed
chore: update comments
vaibhavtiwari33
committed
chore: make codegen
vaibhavtiwari33
committed

Commits on Jun 3, 2026

Commits on Jun 4, 2026

Commits on Jun 7, 2026

chore: tests to cover streaming source scenarios where transformer and bypass router are Some
vaibhavtiwari33
committed