public class InvalidStateStorePartitionException extends InvalidStateStoreException
StoreQueryParameters
used a partitioning that is not assigned to this instance.
You can use KafkaStreams.metadataForAllStreamsClients()
to discover the correct instance that hosts the requested partition.Constructor and Description |
---|
InvalidStateStorePartitionException(String message) |
InvalidStateStorePartitionException(String message,
Throwable throwable) |
setTaskId, taskId
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString