Class Hierarchy
- java.lang.Object
- org.apache.kafka.streams.errors.DefaultProductionExceptionHandler (implements org.apache.kafka.streams.errors.ProductionExceptionHandler)
- org.apache.kafka.streams.errors.LogAndContinueExceptionHandler (implements org.apache.kafka.streams.errors.DeserializationExceptionHandler)
- org.apache.kafka.streams.errors.LogAndFailExceptionHandler (implements org.apache.kafka.streams.errors.DeserializationExceptionHandler)
- java.lang.Throwable (implements java.io.Serializable)
- java.lang.Exception
- java.lang.RuntimeException
- org.apache.kafka.common.KafkaException
- org.apache.kafka.streams.errors.StreamsException
- org.apache.kafka.streams.errors.BrokerNotFoundException
- org.apache.kafka.streams.errors.InvalidStateStoreException
- org.apache.kafka.streams.errors.InvalidStateStorePartitionException
- org.apache.kafka.streams.errors.StateStoreMigratedException
- org.apache.kafka.streams.errors.StateStoreNotAvailableException
- org.apache.kafka.streams.errors.StreamsNotStartedException
- org.apache.kafka.streams.errors.StreamsRebalancingException
- org.apache.kafka.streams.errors.UnknownStateStoreException
- org.apache.kafka.streams.errors.LockException
- org.apache.kafka.streams.errors.MissingSourceTopicException
- org.apache.kafka.streams.errors.ProcessorStateException
- org.apache.kafka.streams.errors.TaskAssignmentException
- org.apache.kafka.streams.errors.TaskCorruptedException
- org.apache.kafka.streams.errors.TaskIdFormatException
- org.apache.kafka.streams.errors.TaskMigratedException
- org.apache.kafka.streams.errors.TopologyException
- org.apache.kafka.streams.errors.StreamsException
- org.apache.kafka.common.KafkaException
- java.lang.RuntimeException
- java.lang.Exception
Interface Hierarchy
- org.apache.kafka.common.Configurable
- org.apache.kafka.streams.errors.DeserializationExceptionHandler
- org.apache.kafka.streams.errors.ProductionExceptionHandler
- org.apache.kafka.streams.errors.StreamsUncaughtExceptionHandler
Enum Class Hierarchy
- java.lang.Object
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)
- org.apache.kafka.streams.errors.DeserializationExceptionHandler.DeserializationHandlerResponse
- org.apache.kafka.streams.errors.ProductionExceptionHandler.ProductionExceptionHandlerResponse
- org.apache.kafka.streams.errors.StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)