Package org.apache.kafka.streams.errors

Interface Summary

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.

Class Summary

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 Summary

Enum	Description
DeserializationExceptionHandler.DeserializationHandlerResponse	Enumeration that describes the response from the exception handler.
ProductionExceptionHandler.ProductionExceptionHandlerResponse

Exception Summary

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.
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.