Count will always use a StateStore, but if you want you can use an InMemory
store if you don't want a persistent store. You can do this by using the
overloaded `count(StateStoreSupplier)` method. You would use
`Stores.create(name).inMemory()...` to create the inmemory store
On Wed, 1 Nov 2017 at 1
i have created 3 inputtopics with 10 partitions each and output Topic with
10 partitions
I did wordcount example and stored it in GlobalKTable.
i initally stored counted value in LocalStateStore and then it to
GlobalStateStore.
i have atteated the code here:
https://gist.github.com/Pk007790/d46
i have created 3 topics with 10 partitions each
i have intended to store processed information in globalKtable
now i have did with individual Ktable to Output topic then to GlobalKtable
#//
KStreamBuilder builder=new KStreamBuilder();
KStream inputStream =
builder.stream(INPUT_TOPICA,INPUT_TOPI
