Hierarchy For Package org.apache.kafka.streams.errors

Package Hierarchies:

• All Packages

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.LogAndContinueProcessingExceptionHandler (implements org.apache.kafka.streams.errors.ProcessingExceptionHandler)
  • org.apache.kafka.streams.errors.LogAndFailExceptionHandler (implements org.apache.kafka.streams.errors.DeserializationExceptionHandler)
  • org.apache.kafka.streams.errors.LogAndFailProcessingExceptionHandler (implements org.apache.kafka.streams.errors.ProcessingExceptionHandler)
  • 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.StreamsStoppedException
              • 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.UnknownTopologyException

Interface Hierarchy

• org.apache.kafka.common.Configurable
  • org.apache.kafka.streams.errors.DeserializationExceptionHandler
  • org.apache.kafka.streams.errors.ProcessingExceptionHandler
  • org.apache.kafka.streams.errors.ProductionExceptionHandler
• org.apache.kafka.streams.errors.ErrorHandlerContext
• 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.ProcessingExceptionHandler.ProcessingHandlerResponse
    • org.apache.kafka.streams.errors.ProductionExceptionHandler.ProductionExceptionHandlerResponse
    • org.apache.kafka.streams.errors.ProductionExceptionHandler.SerializationExceptionOrigin
    • org.apache.kafka.streams.errors.StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse