org.apache.kafka.streams.errors

Interfaces

• DeserializationExceptionHandler
• ProductionExceptionHandler
• StreamsUncaughtExceptionHandler

Classes

• DefaultProductionExceptionHandler
• LogAndContinueExceptionHandler
• LogAndFailExceptionHandler

Enums

• DeserializationExceptionHandler.DeserializationHandlerResponse
• ProductionExceptionHandler.ProductionExceptionHandlerResponse
• StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse

Exceptions

• BrokerNotFoundException
• InvalidStateStoreException
• InvalidStateStorePartitionException
• LockException
• MissingSourceTopicException
• ProcessorStateException
• StateStoreMigratedException
• StateStoreNotAvailableException
• StreamsException
• StreamsNotStartedException
• StreamsRebalancingException
• TaskAssignmentException
• TaskCorruptedException
• TaskIdFormatException
• TaskMigratedException
• TopologyException
• UnknownStateStoreException