Package org.apache.kafka.streams.errors

Class InvalidStateStorePartitionException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

org.apache.kafka.common.KafkaException

org.apache.kafka.streams.errors.StreamsException

org.apache.kafka.streams.errors.InvalidStateStoreException

org.apache.kafka.streams.errors.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:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
InvalidStateStorePartitionException(String message)
InvalidStateStorePartitionException(String message, Throwable throwable)

Method Summary

Methods inherited from class org.apache.kafka.streams.errors.StreamsException

setTaskId, taskId

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

InvalidStateStorePartitionException

public InvalidStateStorePartitionException(String message)

InvalidStateStorePartitionException

public InvalidStateStorePartitionException(String message,
 Throwable throwable)