[ https://issues.apache.org/jira/browse/KAFKA-7445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16633953#comment-16633953 ]
Dennis Reiter commented on KAFKA-7445: -------------------------------------- [~mjsax]: Thanks for the hint! I will give it a try. [~guozhang]: I didn't want to change the branching logic, just using it as an example. > 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 > Priority: Minor > > 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)