Re: GlobalKTable/KTable initialization differences

2018-09-06 Thread Patrik Kleindl
Thank you, looking forward to testing it :-) Best regards Patrik > Am 06.09.2018 um 02:24 schrieb Matthias J. Sax : > > I create https://issues.apache.org/jira/browse/KAFKA-7380 to track this. > > -Matthias > >> On 8/27/18 12:07 PM, Guozhang Wang wrote: >> Hello Patrik, >> >> Thanks for the em

Re: GlobalKTable/KTable initialization differences

2018-09-05 Thread Matthias J. Sax
I create https://issues.apache.org/jira/browse/KAFKA-7380 to track this. -Matthias On 8/27/18 12:07 PM, Guozhang Wang wrote: > Hello Patrik, > > Thanks for the email and this is indeed a good question! :) > > There are some historic reasons that we did the global state restoration in > a differ

Re: GlobalKTable/KTable initialization differences

2018-08-27 Thread Guozhang Wang
Hello Patrik, Thanks for the email and this is indeed a good question! :) There are some historic reasons that we did the global state restoration in a different way, because the restoration logic refactoring comes after global KTable and global stores were introduced. But long story short, I agr

GlobalKTable/KTable initialization differences

2018-08-25 Thread Patrik Kleindl
Hello We are currently using GlobalKTables for interactive queries as well as for lookups inside stream applications but have come across some limitations/problems. The main problem was that our deployments including application start took longer with every new global state store we added which ca