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

Merged

je-ik merged 3 commits into

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

junaiddshaukat:feat/ks-redistribute-and-typeagnostic

Jun 10, 2026

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