[jira] [Created] (KAFKA-5924) Add the compose method to the Kafka Stream API

["Laurent T (JIRA)" <ji...@apache.org>]

Laurent T created KAFKA-5924:
--------------------------------

             Summary: Add the compose method to the Kafka Stream API
                 Key: KAFKA-5924
                 URL: https://issues.apache.org/jira/browse/KAFKA-5924
             Project: Kafka
          Issue Type: Wish
          Components: streams
            Reporter: Laurent T
            Priority: Minor


Hi,

I'm referencing RxJava for it's [compose method|https://github.com/ReactiveX/RxJava/wiki/Implementing-Your-Own-Operators#transformational-operators] which is very handy. It would be great if the Streams API would give us something similar. It's pretty easy to implement and allows to have much more clarity to the code (it avoids breaking the linearity of the code when you want to reuse parts of the stream topology). e.g.

Without compose:
{code:java}
TopologyUtils
    .myUtil(topology
        .map(...)
        .flatMap(...)
        .through(...))
    .map(...)
    .to(...);
{code}

With compose:
{code:java}
topology
    .map(...)
    .flatMap(...)
    .through(...)
    .compose(TopologyUtils::myUtil)
    .map(...)
    .to(...);
{code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)