conduktor.io ↗

KIP-857 — Streaming recursion in Kafka Streams

Discussion Streams

Adds a `KStream.recursively(UnaryOperator<KStream> op)` DSL operator that pipes a stream's output back into an earlier stage of the same topology, enabling iterative graph traversal and recursive algorithms natively. Recursive patterns currently require separate loopback topics and a second `KafkaStreams` instance, incurring extra serialization, latency, and operational complexity.

Details

AuthorNicholas Telford
StatusDiscussion
JIRAKAFKA-14110
WikiView on Apache Wiki
Created2022-07-26
Last Modified2022-09-06
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.