Exception | Description |
---|---|
InvalidStateStoreException |
Indicates that there was a problem when trying to access a
StateStore , i.e, the Store is no longer valid because it is
closed or doesn't exist any more due to a rebalance. |
LockException |
Indicates that the state store directory lock could not be acquired because another thread holds the lock.
|
ProcessorStateException |
Indicates a processor state operation (e.g.
|
StreamsException |
StreamsException is the top-level exception type generated by Kafka Streams. |
TaskAssignmentException |
Indicates a run time error incurred while trying to assign
stream tasks to
threads . |
TaskIdFormatException |
Indicates a run time error incurred while trying parse the
task id
from the read string. |
TopologyBuilderException |
Indicates a pre-run time error incurred while parsing the
builder to construct the processor topology . |