Hierarchy For All Packages

Package Hierarchies:

• org.springframework.kafka,
• org.springframework.kafka.annotation,
• org.springframework.kafka.config,
• org.springframework.kafka.core,
• org.springframework.kafka.event,
• org.springframework.kafka.listener,
• org.springframework.kafka.listener.adapter,
• org.springframework.kafka.listener.config,
• org.springframework.kafka.security.jaas,
• org.springframework.kafka.support,
• org.springframework.kafka.support.converter,
• org.springframework.kafka.support.serializer,
• org.springframework.kafka.test.assertj,
• org.springframework.kafka.test.context,
• org.springframework.kafka.test.core,
• org.springframework.kafka.test.hamcrest,
• org.springframework.kafka.test.rule,
• org.springframework.kafka.test.utils,
• org.springframework.kafka.transaction

Class Hierarchy

• java.lang.Object
  • org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter<T> (implements org.springframework.kafka.listener.ConsumerSeekAware, org.springframework.kafka.listener.DelegatingMessageListener<T>)
    • org.springframework.kafka.listener.adapter.AbstractFilteringMessageListener<K,V,T>
      • org.springframework.kafka.listener.adapter.FilteringBatchMessageListenerAdapter<K,V> (implements org.springframework.kafka.listener.BatchAcknowledgingConsumerAwareMessageListener<K,V>)
      • org.springframework.kafka.listener.adapter.FilteringMessageListenerAdapter<K,V> (implements org.springframework.kafka.listener.AcknowledgingConsumerAwareMessageListener<K,V>)
    • org.springframework.kafka.listener.adapter.AbstractRetryingMessageListenerAdapter<K,V,T>
      • org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter<K,V> (implements org.springframework.kafka.listener.AcknowledgingConsumerAwareMessageListener<K,V>)
  • org.springframework.beans.factory.config.AbstractFactoryBean<T> (implements org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean<T>, org.springframework.beans.factory.InitializingBean)
    • org.springframework.kafka.core.StreamsBuilderFactoryBean (implements org.springframework.context.SmartLifecycle)
  • org.springframework.kafka.support.converter.AbstractJavaTypeMapper (implements org.springframework.beans.factory.BeanClassLoaderAware)
    • org.springframework.kafka.support.converter.DefaultJackson2JavaTypeMapper (implements org.springframework.kafka.support.converter.ClassMapper, org.springframework.kafka.support.converter.Jackson2JavaTypeMapper)
  • org.springframework.kafka.config.AbstractKafkaListenerContainerFactory<C,K,V> (implements org.springframework.context.ApplicationEventPublisherAware, org.springframework.kafka.config.KafkaListenerContainerFactory<C>)
    • org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<K,V>
  • org.springframework.kafka.config.AbstractKafkaListenerEndpoint<K,V> (implements org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, org.springframework.kafka.config.KafkaListenerEndpoint)
    • org.springframework.kafka.config.MethodKafkaListenerEndpoint<K,V>
      • org.springframework.kafka.config.MultiMethodKafkaListenerEndpoint<K,V>
  • org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> (implements org.springframework.context.ApplicationEventPublisherAware, org.springframework.beans.factory.BeanNameAware, org.springframework.kafka.listener.MessageListenerContainer, org.springframework.context.SmartLifecycle)
    • org.springframework.kafka.listener.ConcurrentMessageListenerContainer<K,V>
    • org.springframework.kafka.listener.KafkaMessageListenerContainer<K,V>
  • org.springframework.transaction.support.AbstractPlatformTransactionManager (implements org.springframework.transaction.PlatformTransactionManager, java.io.Serializable)
    • org.springframework.kafka.transaction.KafkaTransactionManager<K,V> (implements org.springframework.transaction.support.ResourceTransactionManager)
  • org.hamcrest.BaseMatcher<T> (implements org.hamcrest.Matcher<T>)
    • org.hamcrest.DiagnosingMatcher<T>
      • org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordKeyMatcher<K>
      • org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordPartitionMatcher
      • org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordTimestampMatcher
      • org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordValueMatcher<V>
  • org.springframework.kafka.listener.BatchLoggingErrorHandler (implements org.springframework.kafka.listener.BatchErrorHandler)
  • org.springframework.kafka.support.converter.BatchMessagingMessageConverter (implements org.springframework.kafka.support.converter.BatchMessageConverter)
  • org.springframework.kafka.test.core.BrokerAddress
  • org.springframework.kafka.core.CleanupConfig
  • org.assertj.core.api.Condition<T> (implements org.assertj.core.api.Descriptable<S>)
    • org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordKeyCondition<K>
    • org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordPartitionCondition
    • org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordTimestampCondition
    • org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordValueCondition<V>
  • org.springframework.kafka.listener.config.ContainerProperties
  • org.springframework.kafka.listener.ContainerStoppingBatchErrorHandler (implements org.springframework.kafka.listener.ContainerAwareBatchErrorHandler)
  • org.springframework.kafka.listener.ContainerStoppingErrorHandler (implements org.springframework.kafka.listener.ContainerAwareErrorHandler)
  • org.springframework.kafka.test.utils.ContainerTestUtils
  • org.springframework.kafka.core.DefaultKafkaConsumerFactory<K,V> (implements org.springframework.kafka.core.ConsumerFactory<K,V>)
  • org.springframework.kafka.support.DefaultKafkaHeaderMapper (implements org.springframework.kafka.support.KafkaHeaderMapper)
  • org.springframework.kafka.support.DefaultKafkaHeaderMapper.NonTrustedHeaderType
  • org.springframework.kafka.support.DefaultKafkaHeaderMapper.SimplePatternBasedHeaderMatcher
  • org.springframework.kafka.core.DefaultKafkaProducerFactory<K,V> (implements org.springframework.beans.factory.DisposableBean, org.springframework.context.Lifecycle, org.springframework.kafka.core.ProducerFactory<K,V>)
  • org.springframework.kafka.listener.adapter.DelegatingInvocableHandler
  • java.util.EventObject (implements java.io.Serializable)
    • org.springframework.context.ApplicationEvent
      • org.springframework.kafka.event.KafkaEvent
        • org.springframework.kafka.event.ListenerContainerIdleEvent
        • org.springframework.kafka.event.NonResponsiveConsumerEvent
  • org.junit.rules.ExternalResource (implements org.junit.rules.TestRule)
    • org.springframework.kafka.test.rule.KafkaEmbedded (implements org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.kafka.test.rule.KafkaRule)
  • org.springframework.kafka.listener.adapter.HandlerAdapter
  • org.springframework.kafka.support.JacksonPresent
  • com.fasterxml.jackson.databind.JsonDeserializer<T> (implements com.fasterxml.jackson.databind.deser.NullValueProvider)
    • com.fasterxml.jackson.databind.deser.std.StdDeserializer<T> (implements java.io.Serializable)
      • com.fasterxml.jackson.databind.deser.std.StdNodeBasedDeserializer<T> (implements com.fasterxml.jackson.databind.deser.ResolvableDeserializer)
        • org.springframework.kafka.support.MimeTypeJsonDeserializer
  • org.springframework.kafka.support.serializer.JsonDeserializer<T> (implements org.apache.kafka.common.serialization.ExtendedDeserializer<T>)
  • org.springframework.kafka.support.serializer.JsonSerde<T> (implements org.apache.kafka.common.serialization.Serde<T>)
  • org.springframework.kafka.support.serializer.JsonSerializer<T> (implements org.apache.kafka.common.serialization.ExtendedSerializer<T>)
  • org.springframework.kafka.core.KafkaAdmin (implements org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.SmartInitializingSingleton)
  • org.springframework.kafka.annotation.KafkaBootstrapConfiguration
  • org.springframework.kafka.test.assertj.KafkaConditions
  • org.springframework.kafka.support.KafkaHeaders
  • org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer (implements org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.SmartInitializingSingleton)
  • org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor<K,V> (implements org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.config.BeanPostProcessor, org.springframework.core.Ordered, org.springframework.beans.factory.SmartInitializingSingleton)
  • org.springframework.kafka.config.KafkaListenerConfigUtils
  • org.springframework.kafka.config.KafkaListenerEndpointRegistrar (implements org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean)
  • org.springframework.kafka.config.KafkaListenerEndpointRegistry (implements org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<E>, org.springframework.beans.factory.DisposableBean, org.springframework.context.SmartLifecycle)
  • org.springframework.kafka.test.hamcrest.KafkaMatchers
  • org.springframework.kafka.support.KafkaNull
  • org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration
  • org.springframework.kafka.core.KafkaTemplate<K,V> (implements org.springframework.kafka.core.KafkaOperations<K,V>)
  • org.springframework.kafka.test.utils.KafkaTestUtils
  • org.springframework.kafka.listener.ListenerUtils
  • org.springframework.kafka.test.rule.Log4jLevelAdjuster (implements org.junit.rules.MethodRule)
  • org.springframework.kafka.listener.LoggingErrorHandler (implements org.springframework.kafka.listener.ErrorHandler)
  • org.springframework.kafka.support.LogIfLevelEnabled
  • org.springframework.messaging.MessageHeaders (implements java.util.Map<K,V>, java.io.Serializable)
    • org.springframework.kafka.support.converter.KafkaMessageHeaders
  • org.springframework.kafka.support.converter.MessagingMessageConverter (implements org.springframework.kafka.support.converter.RecordMessageConverter)
    • org.springframework.kafka.support.converter.ProjectingMessageConverter
    • org.springframework.kafka.support.converter.StringJsonMessageConverter
  • org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter<K,V> (implements org.springframework.kafka.listener.ConsumerSeekAware)
    • org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter<K,V> (implements org.springframework.kafka.listener.BatchAcknowledgingConsumerAwareMessageListener<K,V>)
    • org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter<K,V> (implements org.springframework.kafka.listener.AcknowledgingConsumerAwareMessageListener<K,V>)
  • org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.ReplyExpressionRoot
  • org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.ResultHolder
  • org.springframework.kafka.core.ProducerFactoryUtils
  • org.springframework.kafka.support.ProducerListenerAdapter<K,V> (implements org.springframework.kafka.support.ProducerListener<K,V>)
    • org.springframework.kafka.support.LoggingProducerListener<K,V>
  • org.springframework.transaction.support.ResourceHolderSupport (implements org.springframework.transaction.support.ResourceHolder)
    • org.springframework.kafka.core.KafkaResourceHolder<K,V>
  • org.springframework.kafka.listener.SeekToCurrentBatchErrorHandler (implements org.springframework.kafka.listener.ContainerAwareBatchErrorHandler)
  • org.springframework.kafka.listener.SeekToCurrentErrorHandler (implements org.springframework.kafka.listener.ContainerAwareErrorHandler)
  • org.springframework.kafka.support.SendResult<K,V>
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • org.springframework.core.NestedRuntimeException
          • org.springframework.kafka.KafkaException
            • org.springframework.kafka.support.converter.ConversionException
            • org.springframework.kafka.core.KafkaProducerException
            • org.springframework.kafka.listener.ListenerExecutionFailedException
  • org.springframework.kafka.support.TopicPartitionInitialOffset

Interface Hierarchy

• org.springframework.kafka.support.Acknowledgment
• org.springframework.kafka.support.converter.ClassMapper
  • org.springframework.kafka.support.converter.Jackson2JavaTypeMapper
• org.springframework.kafka.core.ConsumerFactory<K,V>
• org.apache.kafka.clients.consumer.ConsumerRebalanceListener
  • org.springframework.kafka.listener.ConsumerAwareRebalanceListener
• org.springframework.kafka.listener.ConsumerSeekAware
• org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback
• org.springframework.kafka.listener.DelegatingMessageListener<T>
• org.springframework.kafka.listener.GenericErrorHandler<T>
  • org.springframework.kafka.listener.BatchErrorHandler
    • org.springframework.kafka.listener.ConsumerAwareBatchErrorHandler
      • org.springframework.kafka.listener.ContainerAwareBatchErrorHandler
    • org.springframework.kafka.listener.ContainerAwareBatchErrorHandler
  • org.springframework.kafka.listener.ConsumerAwareBatchErrorHandler
    • org.springframework.kafka.listener.ContainerAwareBatchErrorHandler
  • org.springframework.kafka.listener.ConsumerAwareErrorHandler
    • org.springframework.kafka.listener.ContainerAwareErrorHandler
    • org.springframework.kafka.listener.RemainingRecordsErrorHandler
      • org.springframework.kafka.listener.ContainerAwareErrorHandler
  • org.springframework.kafka.listener.ContainerAwareBatchErrorHandler
  • org.springframework.kafka.listener.ContainerAwareErrorHandler
  • org.springframework.kafka.listener.ErrorHandler
    • org.springframework.kafka.listener.ConsumerAwareErrorHandler
      • org.springframework.kafka.listener.ContainerAwareErrorHandler
      • org.springframework.kafka.listener.RemainingRecordsErrorHandler
        • org.springframework.kafka.listener.ContainerAwareErrorHandler
    • org.springframework.kafka.listener.ContainerAwareErrorHandler
    • org.springframework.kafka.listener.RemainingRecordsErrorHandler
      • org.springframework.kafka.listener.ContainerAwareErrorHandler
  • org.springframework.kafka.listener.RemainingRecordsErrorHandler
    • org.springframework.kafka.listener.ContainerAwareErrorHandler
• org.springframework.kafka.listener.GenericMessageListener<T>
  • org.springframework.kafka.listener.AcknowledgingConsumerAwareMessageListener<K,V>
  • org.springframework.kafka.listener.AcknowledgingMessageListener<K,V>
  • org.springframework.kafka.listener.BatchAcknowledgingConsumerAwareMessageListener<K,V>
  • org.springframework.kafka.listener.BatchAcknowledgingMessageListener<K,V>
  • org.springframework.kafka.listener.BatchConsumerAwareMessageListener<K,V>
  • org.springframework.kafka.listener.BatchMessageListener<K,V>
    • org.springframework.kafka.listener.BatchAcknowledgingConsumerAwareMessageListener<K,V>
    • org.springframework.kafka.listener.BatchAcknowledgingMessageListener<K,V>
    • org.springframework.kafka.listener.BatchConsumerAwareMessageListener<K,V>
  • org.springframework.kafka.listener.ConsumerAwareMessageListener<K,V>
  • org.springframework.kafka.listener.MessageListener<K,V>
    • org.springframework.kafka.listener.AcknowledgingConsumerAwareMessageListener<K,V>
    • org.springframework.kafka.listener.AcknowledgingMessageListener<K,V>
    • org.springframework.kafka.listener.ConsumerAwareMessageListener<K,V>
• org.springframework.kafka.support.KafkaHeaderMapper
• org.springframework.kafka.annotation.KafkaListenerConfigurer
• org.springframework.kafka.config.KafkaListenerContainerFactory<C>
• org.springframework.kafka.config.KafkaListenerEndpoint
• org.springframework.kafka.listener.KafkaListenerErrorHandler
  • org.springframework.kafka.listener.ConsumerAwareListenerErrorHandler
• org.springframework.kafka.core.KafkaOperations<K,V>
• org.springframework.kafka.core.KafkaOperations.OperationsCallback<K,V,T>
• org.springframework.kafka.core.KafkaOperations.ProducerCallback<K,V,T>
• org.springframework.context.Lifecycle
  • org.springframework.context.SmartLifecycle (also extends org.springframework.context.Phased)
    • org.springframework.kafka.listener.MessageListenerContainer
• org.springframework.kafka.support.converter.MessageConverter
  • org.springframework.kafka.support.converter.BatchMessageConverter
  • org.springframework.kafka.support.converter.RecordMessageConverter
• org.springframework.context.Phased
  • org.springframework.context.SmartLifecycle (also extends org.springframework.context.Lifecycle)
    • org.springframework.kafka.listener.MessageListenerContainer
• org.springframework.kafka.core.ProducerFactory<K,V>
• org.springframework.kafka.support.ProducerListener<K,V>
• org.springframework.kafka.listener.adapter.RecordFilterStrategy<K,V>
• org.junit.rules.TestRule
  • org.springframework.kafka.test.rule.KafkaRule

Annotation Type Hierarchy

• org.springframework.kafka.annotation.TopicPartition (implements java.lang.annotation.Annotation)
• org.springframework.kafka.annotation.EnableKafkaStreams (implements java.lang.annotation.Annotation)
• org.springframework.kafka.annotation.EnableKafka (implements java.lang.annotation.Annotation)
• org.springframework.kafka.annotation.KafkaListener (implements java.lang.annotation.Annotation)
• org.springframework.kafka.annotation.KafkaListeners (implements java.lang.annotation.Annotation)
• org.springframework.kafka.annotation.PartitionOffset (implements java.lang.annotation.Annotation)
• org.springframework.kafka.annotation.KafkaHandler (implements java.lang.annotation.Annotation)
• org.springframework.kafka.test.context.EmbeddedKafka (implements java.lang.annotation.Annotation)

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.springframework.kafka.listener.AbstractMessageListenerContainer.AckMode
    • org.springframework.kafka.listener.ListenerType
    • org.springframework.kafka.support.LogIfLevelEnabled.Level
    • org.springframework.kafka.support.TopicPartitionInitialOffset.SeekPosition
    • org.springframework.kafka.support.converter.Jackson2JavaTypeMapper.TypePrecedence
    • org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer.ControlFlag