[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16180479#comment-16180479 ] ASF GitHub Bot commented on KAFKA-5765: --- Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3916 > Move merge() from StreamsBuilder to KStream > --- > > Key: KAFKA-5765 > URL: https://issues.apache.org/jira/browse/KAFKA-5765 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 0.11.0.0, 1.0.0 >Reporter: Matthias J. Sax >Assignee: Richard Yu > Labels: needs-kip, newbie > Fix For: 1.0.0 > > Attachments: 5765.v1.patch > > > Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally > {{KStreamBuilder#merge()}}). This is quite unnatural and should be done via > {{KStream#merge()}}. > We need a KIP as we add a new method to a public {{KStreams}} API and > deprecate the old {{merge()}} method. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16172663#comment-16172663 ] ASF GitHub Bot commented on KAFKA-5765: --- GitHub user ConcurrencyPractitioner opened a pull request: https://github.com/apache/kafka/pull/3916 KAFKA-5765 Move merge() from StreamsBuilder to KStream You can merge this pull request into a Git repository by running: $ git pull https://github.com/ConcurrencyPractitioner/kafka trunk Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3916.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3916 commit 709e850de935887881379c1dd3ed4701895c55a7 Author: Richard Yu Date: 2017-09-20T03:12:44Z KAFKA-5765 Polished version of merge > Move merge() from StreamsBuilder to KStream > --- > > Key: KAFKA-5765 > URL: https://issues.apache.org/jira/browse/KAFKA-5765 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 0.11.0.0, 1.0.0 >Reporter: Matthias J. Sax >Assignee: Richard Yu > Labels: needs-kip, newbie > Fix For: 1.1.0 > > Attachments: 5765.v1.patch > > > Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally > {{KStreamBuilder#merge()}}). This is quite unnatural and should be done via > {{KStream#merge()}}. > We need a KIP as we add a new method to a public {{KStreams}} API and > deprecate the old {{merge()}} method. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16172625#comment-16172625 ] ASF GitHub Bot commented on KAFKA-5765: --- Github user ConcurrencyPractitioner closed the pull request at: https://github.com/apache/kafka/pull/3880 > Move merge() from StreamsBuilder to KStream > --- > > Key: KAFKA-5765 > URL: https://issues.apache.org/jira/browse/KAFKA-5765 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 0.11.0.0, 1.0.0 >Reporter: Matthias J. Sax >Assignee: Richard Yu > Labels: needs-kip, newbie > Fix For: 1.1.0 > > Attachments: 5765.v1.patch > > > Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally > {{KStreamBuilder#merge()}}). This is quite unnatural and should be done via > {{KStream#merge()}}. > We need a KIP as we add a new method to a public {{KStreams}} API and > deprecate the old {{merge()}} method. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16169444#comment-16169444 ] ASF GitHub Bot commented on KAFKA-5765: --- GitHub user ConcurrencyPractitioner reopened a pull request: https://github.com/apache/kafka/pull/3880 KAFKA-5765 Move merge() from StreamsBuilder to KStream I have defined a {{merge()}} method to KStream. KStreamImpl overrides the {{merge()}} method. You can merge this pull request into a Git repository by running: $ git pull https://github.com/ConcurrencyPractitioner/kafka trunk Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3880.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3880 commit 572f5bfa5a0e334c5b75a6e3353aa6f4b5b95f39 Author: Richard Yu Date: 2017-09-16T23:38:53Z KAFKA-5765 diff --git a/streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java b/streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java commit 71ac422ceb86e5c1d368a714b0af743eb2ad62eb Author: Richard Yu Date: 2017-09-16T23:54:10Z KAFKA-5765 Move merge() from StreamsBuilder to KStream > Move merge() from StreamsBuilder to KStream > --- > > Key: KAFKA-5765 > URL: https://issues.apache.org/jira/browse/KAFKA-5765 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 0.11.0.0, 1.0.0 >Reporter: Matthias J. Sax >Assignee: Richard Yu > Labels: needs-kip, newbie > Fix For: 1.1.0 > > Attachments: 5765.v1.patch > > > Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally > {{KStreamBuilder#merge()}}). This is quite unnatural and should be done via > {{KStream#merge()}}. > We need a KIP as we add a new method to a public {{KStreams}} API and > deprecate the old {{merge()}} method. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16169331#comment-16169331 ] ASF GitHub Bot commented on KAFKA-5765: --- Github user ConcurrencyPractitioner closed the pull request at: https://github.com/apache/kafka/pull/3880 > Move merge() from StreamsBuilder to KStream > --- > > Key: KAFKA-5765 > URL: https://issues.apache.org/jira/browse/KAFKA-5765 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 0.11.0.0, 1.0.0 >Reporter: Matthias J. Sax >Assignee: Richard Yu > Labels: needs-kip, newbie > Fix For: 1.1.0 > > Attachments: 5765.v1.patch > > > Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally > {{KStreamBuilder#merge()}}). This is quite unnatural and should be done via > {{KStream#merge()}}. > We need a KIP as we add a new method to a public {{KStreams}} API and > deprecate the old {{merge()}} method. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16169140#comment-16169140 ] ASF GitHub Bot commented on KAFKA-5765: --- GitHub user ConcurrencyPractitioner reopened a pull request: https://github.com/apache/kafka/pull/3880 KAFKA-5765 Move merge() from StreamsBuilder to KStream I have defined a {{merge()}} method to KStream. KStreamImpl overrides the {{merge()}} method. You can merge this pull request into a Git repository by running: $ git pull https://github.com/ConcurrencyPractitioner/kafka trunk Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3880.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3880 commit 572f5bfa5a0e334c5b75a6e3353aa6f4b5b95f39 Author: Richard Yu Date: 2017-09-16T23:38:53Z KAFKA-5765 diff --git a/streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java b/streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java commit 71ac422ceb86e5c1d368a714b0af743eb2ad62eb Author: Richard Yu Date: 2017-09-16T23:54:10Z KAFKA-5765 Move merge() from StreamsBuilder to KStream > Move merge() from StreamsBuilder to KStream > --- > > Key: KAFKA-5765 > URL: https://issues.apache.org/jira/browse/KAFKA-5765 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 0.11.0.0, 1.0.0 >Reporter: Matthias J. Sax >Assignee: Richard Yu > Labels: needs-kip, newbie > Fix For: 1.1.0 > > Attachments: 5765.v1.patch > > > Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally > {{KStreamBuilder#merge()}}). This is quite unnatural and should be done via > {{KStream#merge()}}. > We need a KIP as we add a new method to a public {{KStreams}} API and > deprecate the old {{merge()}} method. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16169135#comment-16169135 ] ASF GitHub Bot commented on KAFKA-5765: --- Github user ConcurrencyPractitioner closed the pull request at: https://github.com/apache/kafka/pull/3880 > Move merge() from StreamsBuilder to KStream > --- > > Key: KAFKA-5765 > URL: https://issues.apache.org/jira/browse/KAFKA-5765 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 0.11.0.0, 1.0.0 >Reporter: Matthias J. Sax >Assignee: Richard Yu > Labels: needs-kip, newbie > Fix For: 1.1.0 > > Attachments: 5765.v1.patch > > > Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally > {{KStreamBuilder#merge()}}). This is quite unnatural and should be done via > {{KStream#merge()}}. > We need a KIP as we add a new method to a public {{KStreams}} API and > deprecate the old {{merge()}} method. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16169134#comment-16169134 ] ASF GitHub Bot commented on KAFKA-5765: --- GitHub user ConcurrencyPractitioner opened a pull request: https://github.com/apache/kafka/pull/3880 KAFKA-5765 Move merge() from StreamsBuilder to KStream I have defined a {{merge()}} method to KStream. KStreamImpl overrides the {{merge()}} method. You can merge this pull request into a Git repository by running: $ git pull https://github.com/ConcurrencyPractitioner/kafka trunk Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3880.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3880 commit 572f5bfa5a0e334c5b75a6e3353aa6f4b5b95f39 Author: Richard Yu Date: 2017-09-16T23:38:53Z KAFKA-5765 diff --git a/streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java b/streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java > Move merge() from StreamsBuilder to KStream > --- > > Key: KAFKA-5765 > URL: https://issues.apache.org/jira/browse/KAFKA-5765 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 0.11.0.0, 1.0.0 >Reporter: Matthias J. Sax >Assignee: Richard Yu > Labels: needs-kip, newbie > Fix For: 1.1.0 > > Attachments: 5765.v1.patch > > > Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally > {{KStreamBuilder#merge()}}). This is quite unnatural and should be done via > {{KStream#merge()}}. > We need a KIP as we add a new method to a public {{KStreams}} API and > deprecate the old {{merge()}} method. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16169063#comment-16169063 ] Matthias J. Sax commented on KAFKA-5765: [~Yohan123] Thanks for the patch. We do use Github to review and merge patches. Can you please open an PR there? > Move merge() from StreamsBuilder to KStream > --- > > Key: KAFKA-5765 > URL: https://issues.apache.org/jira/browse/KAFKA-5765 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 0.11.0.0, 1.0.0 >Reporter: Matthias J. Sax > Labels: needs-kip, newbie > Fix For: 1.1.0 > > Attachments: 5765.v1.patch > > > Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally > {{KStreamBuilder#merge()}}). This is quite unnatural and should be done via > {{KStream#merge()}}. > We need a KIP as we add a new method to a public {{KStreams}} API and > deprecate the old {{merge()}} method. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168965#comment-16168965 ] Richard Yu commented on KAFKA-5765: --- To my understanding, there should be a {{merge()}} method that is added to the {{KStream}} interface (non-internal). However, that means that no instances of internal classes could be used as an input argument. Meanwhile, the {{KStreamImpl}} class (which is internal) should override this method, but needs access to the corresponding {{InternalStreamsBuilder}} instance for the streams to be merged. Is there a way to access the corresponding {{InternalStreamsBuilder}} instance? > Move merge() from StreamsBuilder to KStream > --- > > Key: KAFKA-5765 > URL: https://issues.apache.org/jira/browse/KAFKA-5765 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 0.11.0.0, 1.0.0 >Reporter: Matthias J. Sax > Labels: needs-kip, newbie > Fix For: 1.1.0 > > > Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally > {{KStreamBuilder#merge()}}). This is quite unnatural and should be done via > {{KStream#merge()}}. > We need a KIP as we add a new method to a public {{KStreams}} API and > deprecate the old {{merge()}} method. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168958#comment-16168958 ] Richard Yu commented on KAFKA-5765: --- Just to clarify on the requirements of the new {{merge()}} method in KStream. Is the method only allowed to have an array of streams as an input argument or is other arguments allowed as well (e.g. StreamBuilder or the like)? > Move merge() from StreamsBuilder to KStream > --- > > Key: KAFKA-5765 > URL: https://issues.apache.org/jira/browse/KAFKA-5765 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 0.11.0.0, 1.0.0 >Reporter: Matthias J. Sax > Labels: needs-kip, newbie > Fix For: 1.1.0 > > > Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally > {{KStreamBuilder#merge()}}). This is quite unnatural and should be done via > {{KStream#merge()}}. > We need a KIP as we add a new method to a public {{KStreams}} API and > deprecate the old {{merge()}} method. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168644#comment-16168644 ] Guozhang Wang commented on KAFKA-5765: -- Richard, I have granted you the permission, cheers. > Move merge() from StreamsBuilder to KStream > --- > > Key: KAFKA-5765 > URL: https://issues.apache.org/jira/browse/KAFKA-5765 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 0.11.0.0, 1.0.0 >Reporter: Matthias J. Sax > Labels: needs-kip, newbie > Fix For: 1.1.0 > > > Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally > {{KStreamBuilder#merge()}}). This is quite unnatural and should be done via > {{KStream#merge()}}. > We need a KIP as we add a new method to a public {{KStreams}} API and > deprecate the old {{merge()}} method. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168623#comment-16168623 ] Richard Yu commented on KAFKA-5765: --- I have requested for wiki edit access, but that is still forthcoming. (My wiki handle is yohan.richard.yu) > Move merge() from StreamsBuilder to KStream > --- > > Key: KAFKA-5765 > URL: https://issues.apache.org/jira/browse/KAFKA-5765 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 0.11.0.0, 1.0.0 >Reporter: Matthias J. Sax > Labels: needs-kip, newbie > Fix For: 1.1.0 > > > Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally > {{KStreamBuilder#merge()}}). This is quite unnatural and should be done via > {{KStream#merge()}}. > We need a KIP as we add a new method to a public {{KStreams}} API and > deprecate the old {{merge()}} method. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168170#comment-16168170 ] Matthias J. Sax commented on KAFKA-5765: Sure. If you need any help with the KIP, let us know. Have a look here to get started https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals (If you don't have wiki access, let us know your wiki ID so we can give you write permission there, \cc [~guozhang] [~damianguy] -- can you also add [~Yohan123] to the contributor list so we can assign this JIRA to him -- this will also allow you to assign JIRA to yourself). Thanks a lot! > Move merge() from StreamsBuilder to KStream > --- > > Key: KAFKA-5765 > URL: https://issues.apache.org/jira/browse/KAFKA-5765 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 0.11.0.0, 1.0.0 >Reporter: Matthias J. Sax > Labels: needs-kip, newbie > Fix For: 1.1.0 > > > Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally > {{KStreamBuilder#merge()}}). This is quite unnatural and should be done via > {{KStream#merge()}}. > We need a KIP as we add a new method to a public {{KStreams}} API and > deprecate the old {{merge()}} method. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167264#comment-16167264 ] Richard Yu commented on KAFKA-5765: --- Could I work on this? Thanks. > Move merge() from StreamsBuilder to KStream > --- > > Key: KAFKA-5765 > URL: https://issues.apache.org/jira/browse/KAFKA-5765 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 0.11.0.0, 1.0.0 >Reporter: Matthias J. Sax > Labels: needs-kip, newbie > Fix For: 1.1.0 > > > Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally > {{KStreamBuilder#merge()}}). This is quite unnatural and should be done via > {{KStream#merge()}}. > We need a KIP as we add a new method to a public {{KStreams}} API and > deprecate the old {{merge()}} method. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137146#comment-16137146 ] Guozhang Wang commented on KAFKA-5765: -- Sounds reasonable to me. > Move merge() from StreamsBuilder to KStream > --- > > Key: KAFKA-5765 > URL: https://issues.apache.org/jira/browse/KAFKA-5765 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 0.11.0.0 >Reporter: Matthias J. Sax >Assignee: Matthias J. Sax > Labels: needs-kip > Fix For: 1.0.0 > > > Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally > {{KStreamBuilder#merge()}}). This is quite unnatural and should be done via > {{KStream#merge()}}. > As {{StreamsBuilder}} is not released yet, this is not a backward > incompatible change (and KStreamBuilder is already deprecated). We still need > a KIP as we add a new method to a public {{KStreams}} API. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream
[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137081#comment-16137081 ] Xavier Léauté commented on KAFKA-5765: -- I have a small request when it comes to merge(). The current varargs form generates a lot of compiler warnings that need to be suppressed using {{@SuppressWarnings("unchecked")}}. Given that the typical merge use-case only involves only a handful of streams, I think it would be useful to provide a couple of overloads that take a fixed number of arguments, similar to what Guave does in [ImmutableList.of(...)|https://google.github.io/guava/releases/21.0/api/docs/com/google/common/collect/ImmutableList.html#of-E-E-E-E-E-E-E-E-E-E-E-] > Move merge() from StreamsBuilder to KStream > --- > > Key: KAFKA-5765 > URL: https://issues.apache.org/jira/browse/KAFKA-5765 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 0.11.0.0 >Reporter: Matthias J. Sax >Assignee: Matthias J. Sax > Labels: needs-kip > > Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally > {{KStreamBuilder#merge()}}). This is quite unnatural and should be done via > {{KStream#merge()}}. > As {{StreamsBuilder}} is not released yet, this is not a backward > incompatible change (and KStreamBuilder is already deprecated). We still need > a KIP as we add a new method to a public {{KStreams}} API. -- This message was sent by Atlassian JIRA (v6.4.14#64029)