Re: Kafka streams KStream and ktable join issue

I thought, we drop records with null key? No? -Matthias On 6/23/17 12:25 AM, Damian Guy wrote: > My guess is it is because the record doesn't have a key, i.e., the key is > null. We have a fix for this in 0.11, in that we will skip records with a > null key during restore. > > On Fri, 23 Jun

Re: Kafka streams KStream and ktable join issue

My guess is it is because the record doesn't have a key, i.e., the key is null. We have a fix for this in 0.11, in that we will skip records with a null key during restore. On Fri, 23 Jun 2017 at 03:57 Matthias J. Sax wrote: > Hi, > > can you reproduce the error reliably?

Re: Kafka streams KStream and ktable join issue

Hi, can you reproduce the error reliably? Are use using 0.10.2.0 or 0.10.2.1? It's unclear to me, how an NPE can occur. It seems to happen within Streams library. Might be a bug. Not sure atm. -Matthias On 6/22/17 9:43 AM, Shekar Tippur wrote: > Hello, > > I am trying to perform a simple

Kafka streams KStream and ktable join issue

Hello, I am trying to perform a simple join operation. I am using Kafka 0.10.2 I have a "raw" table and a "cache" topics and just 1 partition in my local environment. ktable has these entries {"Joe": {"location": "US", "gender": "male"}} {"Julie": {"location": "US", "gender": "female"}}