[GSoC 2026] Kafka Streams runner — Redistribute translator + ExecutableStage type-agnostic edge#38843

Open

junaiddshaukat wants to merge 3 commits into

apache:feat/18479-kafka-streams-runner-skeletonfrom

junaiddshaukat:feat/ks-redistribute-and-typeagnostic

Commits on Jun 8, 2026

Add Redistribute (arbitrarily) translator + type-agnostic ExecutableStage edge
junaiddshaukat
committed

Commits on Jun 9, 2026

Drain pendingOutputs via poll() loop instead of forEach + clear
junaiddshaukat
committed
Assert ChainedExecutableStageTest pipeline actually has two ExecutableStages
junaiddshaukat
committed