You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Marcel Silberhorn (JIRA)" <ji...@apache.org> on 2017/06/21 13:26:00 UTC

[jira] [Created] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index

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)