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, 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.
TaskMigratedException	Indicates that a task got migrated to another thread.
TopologyException	Indicates a pre run time error occurred while parsing the logical topology to construct the physical processor topology.