Re: ReadOnlyKeyValueStore.range API

2018-01-30 Thread Matthias J. Sax
You need to write some custom code using Interactive Queries and implement a scatter-gather pattern. Basically, you need to do the range on each instance and then merge all partial results. https://kafka.apache.org/10/documentation/streams/developer-guide/interactive-queries.html You can also fi

ReadOnlyKeyValueStore.range API

2018-01-29 Thread Debasish Ghosh
Hello - The above API gives me the range of values between fromKey and toKey for a local state store. Suppose I have an application running in distributed mode (multiple nodes same application id). How does this API translate to multiple nodes ? I know the basic implementation is for a local nod