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 > > >