public class InvalidStateStoreException extends StreamsException
StateStore
, i.e, the Store is no longer valid because it is
closed or doesn't exist any more due to a rebalance.
These exceptions may be transient, i.e., during a rebalance it won't be possible to query the stores as they are being (re)-initialized. Once the rebalance has completed the stores will be available again. Hence, it is valid to backoff and retry when handling this exception.
Constructor | Description |
---|---|
InvalidStateStoreException(java.lang.String message) |
|
InvalidStateStoreException(java.lang.String message,
java.lang.Throwable throwable) |
|
InvalidStateStoreException(java.lang.Throwable throwable) |
public InvalidStateStoreException(java.lang.String message)
public InvalidStateStoreException(java.lang.String message, java.lang.Throwable throwable)
public InvalidStateStoreException(java.lang.Throwable throwable)