If you run multiple instances of your app you may not be able to access the
state store you are trying to access from the instance you are trying from,
i.e., it may be on another instance. If streams is in the RUNNING state,
this would seem to be the issue.
On Wed, 7 Mar 2018 at 15:56 detharon
I'm afraid that's not what I'm looking for, as I'm just trying to retrieve
the local data, from inside my application (but from outside the stream
topology), and in some cases it becomes impossible. That is, the stream
changes its state from "rebalancing" to "running", but the store is remains
If you have multiple streams instances then the store might only be
available on one of the instances. Using `KafkaStreams.store(..)` will only
locate stores that are currently accessible by that instance. If you need
to be able to locate stores on other instances, then you should probably
have a
Hello, I'm experiencing issues accessing the state stores outside the Kafka
stream. My application queries the state store every n seconds using the
.all() method to retrieve all key value pairs. I know that the state store
might not be available, so I guard against the InvalidStateStoreException
