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 specifiedbrokers
could be found.InvalidStateStoreException Indicates that there was a problem when trying to access aStateStore
, 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 assignstream tasks
tothreads
.TaskCorruptedException Indicates a specific task is corrupted and need to be re-initialized.TaskIdFormatException Indicates a run time error incurred while trying parse thetask 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 thelogical topology
to construct thephysical processor topology
.