Re: [Kafka Streams] Source Nodes

2016-06-29 Thread mishadoff
Thanks Matthias! Got it working with through, still use 0.10.0.0 version. > On Jun 29, 2016, at 22:42, Matthias J. Sax wrote: > > Hi, > > for joins, data of both inputs must be co-located, ie, partitioned on > the same key and have the same number of partitions: > > See "Note" box at: > http:

Re: [Kafka Streams] Source Nodes

2016-06-29 Thread Matthias J. Sax
Hi, for joins, data of both inputs must be co-located, ie, partitioned on the same key and have the same number of partitions: See "Note" box at: http://docs.confluent.io/3.0.0/streams/developer-guide.html?highlight=join#joining-streams From an older email thread about the same issue: >>> If yo

[Kafka Streams] Source Nodes

2016-06-29 Thread mishadoff
Hey, I am trying to understand kafka-streams and doing a simple prototype for joining KStream with KTable, but stuck at the error: Invalid topology building: KSTREAM-MAP-01 and KSTREAM-AGGREGATE-04 are not joinable I tracked down the issue is thrown where stream or table have s