See: Description
Interface | Description |
---|---|
DeserializationExceptionHandler |
Interface that specifies how an exception from source node deserialization
(e.g., reading from Kafka) should be handled.
|
ProductionExceptionHandler |
Interface that specifies how an exception when attempting to produce a result to
Kafka should be handled.
|
StreamsUncaughtExceptionHandler |
Class | Description |
---|---|
DefaultProductionExceptionHandler |
ProductionExceptionHandler that always instructs streams to fail when an exception
happens while attempting to produce result records. |
LogAndContinueExceptionHandler |
Deserialization handler that logs a deserialization exception and then
signals the processing pipeline to continue processing more records.
|
LogAndFailExceptionHandler |
Deserialization handler that logs a deserialization exception and then
signals the processing pipeline to stop processing more records and fail.
|
Enum | Description |
---|---|
DeserializationExceptionHandler.DeserializationHandlerResponse |
Enumeration that describes the response from the exception handler.
|
ProductionExceptionHandler.ProductionExceptionHandlerResponse | |
StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse |
Enumeration that describes the response from the exception handler.
|
Exception | Description |
---|---|
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 |
StreamsException is the top-level exception type generated by Kafka Streams, and indicates errors have
occurred during a StreamThread's processing. |
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. |
StreamsStoppedException |
Indicates that Kafka Streams is in a terminating or terminal state, such as
KafkaStreams.State.PENDING_SHUTDOWN ,KafkaStreams.State.PENDING_ERROR ,KafkaStreams.State.NOT_RUNNING , or KafkaStreams.State.ERROR . |
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.
|
UnknownTopologyException |
Indicates that the
NamedTopology being
looked up does not exist in this application |