Re: InvalidStateStoreException on KStream join using GlobalKtables

2019-05-09 Thread Ishita Rakshit
Hi Guozhang, I am using Kafka 2.2.0. The issue is resolved now. We had set auto.register.schemas=false as we wanted to manually register the schemas. It got fixed after setting the flag to true as it needs to register schemas for its internal topics. Thanks, Ishita Rakshit On Tue, May 7, 2019 at

Re: InvalidStateStoreException on KStream join using GlobalKtables

2019-05-07 Thread Guozhang Wang
Hello Ishita, Is it consistently reproducing? And which Kafka version are you using? Guozhang On Thu, May 2, 2019 at 5:24 PM Ishita Rakshit wrote: > Hi, > I have a Kafka Streams application where I am joining a KStream that reads > from "topic1" with a GlobalKTable that reads from "topic2" a