Dennis Reiter created KAFKA-7445: ------------------------------------ Summary: Branch one Stream in multiple Streams Key: KAFKA-7445 URL: https://issues.apache.org/jira/browse/KAFKA-7445 Project: Kafka Issue Type: New Feature Components: streams Reporter: Dennis Reiter
Hi, I need to branch/split KStreams in multiple independent KStreams. I thought, {{org.apache.kafka.streams.kstream.internals.KStreamImpl#branch}} is the right one but in fact, its designed for another purpose. In contrast to {{branch}} I need to assign the record to *all* matching streams, not only one stream. Speaking in code ({{org.apache.kafka.streams.kstream.internals.KStreamBranch}}): {code:java} if (predicates[i].test(key, value)) { // use forward with childIndex here // and pipe the record to multiple streams context().forward(key, value, i); } {code} My question: is this still possible with features already included in Streams? Or shall I propose a change? Thanks in advance Dennis -- This message was sent by Atlassian JIRA (v7.6.3#76005)