Hi Sachin,
As Patrik mentioned, KIP-150 is being actively worked on and is likely to
be included in the next release.
Guozhang
On Fri, Dec 6, 2019 at 12:09 AM Patrik Kleindl wrote:
> Hi
>
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-150+-+Kafka-Streams+Cogroup
> might
> be worth a
Hi
https://cwiki.apache.org/confluence/display/KAFKA/KIP-150+-+Kafka-Streams+Cogroup
might
be worth a look.
best regards
Patrik
On Fri, 6 Dec 2019 at 06:44, Sachin Mittal wrote:
> I was thinking more of a builder api at DSL level.
> Something like this:
> StreamsBuilder.joineBuilder()
>
I was thinking more of a builder api at DSL level.
Something like this:
StreamsBuilder.joineBuilder()
.join(kstream1)
.leftJoin(kstream2)
.leftJoin(kstream3)
.joiner((k,v1,v2,v3...) -> ...)
.window(
Hi Sachin,
I do not completely understand what you mean with one single
operation. Do you mean one call of a method in the DSL or the join is
processed on one processor node?
If you mean the latter, the joins in the DSL are also not processed on
one single processor node.
If you mean the former,
Hi,
I have checked the documentation and what I see that we can join two
streams or tables at a given time.
I have a case where I have multiple streams which I need to join based on
common key.
As of now I am first joining two and the result of that with next and so on.
Is there a way or any cas
