kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Marcel Silberhorn (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index
Date Wed, 21 Jun 2017 13:26:00 GMT
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)

Mime
View raw message