Class InvalidStateStorePartitionException

All Implemented Interfaces:
Serializable

public class InvalidStateStorePartitionException extends InvalidStateStoreException
Indicates that the specific state store being queried via 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.
See Also:
  • Constructor Details

    • InvalidStateStorePartitionException

      public InvalidStateStorePartitionException(String message)
    • InvalidStateStorePartitionException

      public InvalidStateStorePartitionException(String message, Throwable throwable)