public class InvalidStateStorePartitionException extends InvalidStateStoreException
StoreQueryParameters
used a partitioning that is not assigned to this instance.
You can use KafkaStreams.allMetadata()
to discover the correct instance that hosts the requested partition.Constructor and Description |
---|
InvalidStateStorePartitionException(java.lang.String message) |
InvalidStateStorePartitionException(java.lang.String message,
java.lang.Throwable throwable) |