BrokerNotFoundException |
Indicates that none of the specified brokers
could be found.
|
InvalidStateStoreException |
Indicates that there was a problem when trying to access a StateStore .
|
InvalidStateStorePartitionException |
Indicates that the specific state store being queried via
StoreQueryParameters used a partitioning that is not assigned to this instance.
|
LockException |
Indicates that the state store directory lock could not be acquired because another thread holds the lock.
|
MissingSourceTopicException |
|
ProcessorStateException |
Indicates a processor state operation (e.g.
|
StateStoreMigratedException |
Indicates that the state store being queried is closed although the Kafka Streams state is
RUNNING or
REBALANCING .
|
StateStoreNotAvailableException |
Indicates that the state store being queried is already closed.
|
StreamsException |
|
StreamsNotStartedException |
Indicates that Kafka Streams is in state CREATED and thus state stores cannot be queries yet.
|
StreamsRebalancingException |
Indicates that Kafka Streams is in state REBALANCING and thus
cannot be queried by default.
|
TaskAssignmentException |
Indicates a run time error incurred while trying to assign
stream tasks to
threads .
|
TaskCorruptedException |
Indicates a specific task is corrupted and need to be re-initialized.
|
TaskIdFormatException |
Indicates a run time error incurred while trying parse the task id
from the read string.
|
TaskMigratedException |
Indicates that all tasks belongs to the thread have migrated to another thread.
|
TopologyException |
Indicates a pre run time error occurred while parsing the logical topology
to construct the physical processor topology .
|
UnknownStateStoreException |
Indicates that the state store being queried is unknown, i.e., the state store does either not exist in your topology
or it is not queryable.
|