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)