Merge pull request #407 from aevatarAI/feat/2026-04-25_streaming-sink… #1500

Job	Run time
slow-test-guards	2m 32s
changes	6s
coverage-quality	15m 14s
split-test-guards	0s
distributed-mixed-version-smoke	0s
distributed-3node-smoke	0s
fast-gates	37s
event-sourcing-regression	4m 45s
projection-provider-e2e	2m 35s
console-web	8m 1s
kafka-transport-integration	9m 23s
	43m 13s

Provide feedback