Hi Damian,
in the blog it is mentioned that, although cumbersome, there is another way
of achievieng the same result.
Something like this.
KTable<K, V1> table1 =
builder.stream("topic1").groupByKey().aggregate(initializer1,
aggregator1, aggValueSerde1, storeName1);
KTable<K, V2> table2 =
builder.stream("topic2").groupByKey().aggregate(initializer2,
aggregator2, aggValueSerde2, storeName2);
KTable<K, V3> table3 =
builder.stream("topic3").groupByKey().aggregate(initializer3,
aggregator3, aggValueSerde3, storeName3);
KTable<K, CG> cogrouped = table1.outerJoin(table2,
joinerOneAndTwo).outerJoin(table3, joinerOneTwoAndThree);
On Mon, Nov 13, 2017 at 3:01 PM, Damian Guy <damian....@gmail.com> wrote:
> Hi,
>
> This KIP didn't make it into 1.0, so it can't be done at the moment.
>
> Thanks,
> Damian
>
> On Mon, 13 Nov 2017 at 14:00 Artur Mrozowski <art...@gmail.com> wrote:
>
> > Hi,
> > I wonder if anyone could shed some light on how to implement CoGroup in
> > Kafka Streams in currrent version 1.0, as mentioned in this blog post
> >
> >
> > https://cwiki.apache.org/confluence/display/KAFKA/KIP-
> 150+-+Kafka-Streams+Cogroup
> > .
> >
> > I am new to Kafka and would appreciate if anyone could provide an example
> > on how this can be done in little more detail.
> >
> > Thanks
> >
> > /Artur
> >
>
