You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Marcel Silberhorn (JIRA)" <ji...@apache.org> on 2017/06/21 13:27:00 UTC
[jira] [Updated] (KAFKA-5488) KStream.branch should not return a
Array of streams we have to access by known index
[ https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Marcel Silberhorn updated KAFKA-5488:
-------------------------------------
Description:
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 BranchDefinition<Predicate<>, Consumer<KStream<>>>... branchPredicatesAndHandlers);}} where you can write branches/streams code nested where it belongs to
was:
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
> 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 BranchDefinition<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)