kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias J. Sax" <matth...@confluent.io>
Subject Re: ReadOnlyKeyValueStore.range API
Date Tue, 30 Jan 2018 21:41:13 GMT
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.


You can also find an example for IQ here:


On 1/29/18 10:49 PM, Debasish Ghosh wrote:
> 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 node. But is there an
> algorithm to implement this range() function for the distributed setting ?
> I can find out the host where fromKey lives, also the host where toKey
> lives. But how do I know the elements in between ?
> Any pointer will be appreciated ..
> regards.

View raw message