Re: Kafka Streams: KStream - KTable Left Join

2016-05-05 Thread Gaspar Muñoz
Thanks, I'll try it. It would be nice if you could improve the error message. 2016-05-04 20:13 GMT+02:00 Matthias J. Sax : > +1 > > I had the same thought and put it on my personal agenda already. > > -Matthias > > On 05/04/2016 06:37 PM, Jay Kreps wrote: > > Is it possible to make the error mess

Re: Kafka Streams: KStream - KTable Left Join

2016-05-04 Thread Matthias J. Sax
+1 I had the same thought and put it on my personal agenda already. -Matthias On 05/04/2016 06:37 PM, Jay Kreps wrote: > Is it possible to make the error message give more an explanation? > > -Jay > > On Wed, May 4, 2016 at 8:46 AM, Matthias J. Sax > wrote: > >> Hi, >> >> I am still new to K

Re: Kafka Streams: KStream - KTable Left Join

2016-05-04 Thread Jay Kreps
Is it possible to make the error message give more an explanation? -Jay On Wed, May 4, 2016 at 8:46 AM, Matthias J. Sax wrote: > Hi, > > I am still new to Kafka Streams by myself, but from my understanding if > you change the key, your partitioning changes, ie, is not valid anymore. > Thus, the

Re: Kafka Streams: KStream - KTable Left Join

2016-05-04 Thread Matthias J. Sax
Hi, I am still new to Kafka Streams by myself, but from my understanding if you change the key, your partitioning changes, ie, is not valid anymore. Thus, the joins (which assumes co-located data) cannot be performed (this is the reason why sources get set to null). You can write to an intermediat

Kafka Streams: KStream - KTable Left Join

2016-05-04 Thread Gaspar Muñoz
Hi there, I am not able to perform a Left Join between a KStream and KTable in Kafka Streams. Exception in thread "main" org.apache.kafka.streams.errors.TopologyBuilderException: Invalid topology building: KSTREAM-FILTER-03 and KTABLE-SOURCE-05 are not joinable at org.apache.kafka