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)