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
| Author | Nicholas Telford |
| Status | Discussion |
| JIRA | KAFKA-14110 |
| Wiki | View on Apache Wiki |
| Created | 2022-07-26 |
| Last Modified | 2022-09-06 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.