Re: Kafka Streams : Problem with Global State Restoration

2017-10-20 Thread Tony John
Hi Damian, Thanks a lot for the response. Just saw your reply when I visited the mailer-list archive . Unfortunately I haven't received the same on my inbox and I didn't even see the update in the archive when I checked earl

Re: Kafka Streams : Problem with Global State Restoration

2017-10-18 Thread Damian Guy
Hi Tony, The issue is that the GlobalStore doesn't use the Processor when restoring the state. It just reads the raw records from the underlying topic. You could work around this by doing the processing and writing to another topic. Then use the other topic as the source for your global-store. It

Kafka Streams : Problem with Global State Restoration

2017-10-18 Thread Tony John
Hello All, I have been trying to create an application on top of Kafka Streams. I am newbie to Kafka & Kakfa streams. So please excuse if I my understanding are wrong. I got the application running fine on a single instance ec2 instance in AWS. Now I am looking at scaling and ran in to some issue