Marcel Silberhorn created KAFKA-5488:
----------------------------------------

             Summary: KStream.branch should not return a Array of streams we 
have to access by known index
                 Key: KAFKA-5488
                 URL: https://issues.apache.org/jira/browse/KAFKA-5488
             Project: Kafka
          Issue Type: Improvement
          Components: streams
    Affects Versions: 0.10.2.1
            Reporter: Marcel Silberhorn


some details and thoughts about:

https://gitlab.com/childno.de/apache_kafka/snippets/1665655

long story short: it's a mess to get a {{KStream<>[]}} out from 
{{KStream<>branch(Predicate<>...)}}. It breaks the fluent API and it produces 
bad code which is not that good to maintain since you have to know the right 
index for an unnamed branching stream.

Quick idea, s.th. like {{void branch(final KeyValue<Predicate<>, 
Consumer<KStream<>>>... branchPredicatesAndHandlers);}} where you can write 
branches/streams code nested where it belongs to



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to