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.

Class Summary

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

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. put, get) has failed.
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	Deprecated use Topology instead of TopologyBuilder
TopologyException	Indicates a pre run time error occurred while parsing the logical topology to construct the physical processor topology.