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

InvalidStateStoreException on KStream join using GlobalKtables

2019-05-02 Thread Ishita Rakshit
Hi, I have a Kafka Streams application where I am joining a KStream that reads from "topic1" with a GlobalKTable that reads from "topic2" and then with another GlobalKTable that reads from "topic3". Here is the pseudo code - > KStream topic1KStream = > builder.stream( >