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.support,
• org.springframework.kafka.support.converter,
• org.springframework.kafka.support.serializer,
• org.springframework.kafka.test.assertj,
• org.springframework.kafka.test.core,
• org.springframework.kafka.test.hamcrest,
• org.springframework.kafka.test.rule,
• org.springframework.kafka.test.utils

Class Hierarchy

• java.lang.Object
  • 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.KStreamBuilderFactoryBean (implements org.springframework.context.SmartLifecycle)
  • 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.adapter.AbstractMessageListenerAdapter<K,V,T> (implements org.springframework.kafka.listener.ConsumerSeekAware)
    • org.springframework.kafka.listener.adapter.AbstractFilteringMessageListener<K,V,T>
      • org.springframework.kafka.listener.adapter.FilteringAcknowledgingMessageListenerAdapter<K,V> (implements org.springframework.kafka.listener.AcknowledgingMessageListener<K,V>)
      • org.springframework.kafka.listener.adapter.FilteringBatchAcknowledgingMessageListenerAdapter<K,V> (implements org.springframework.kafka.listener.BatchAcknowledgingMessageListener<K,V>)
      • org.springframework.kafka.listener.adapter.FilteringBatchMessageListenerAdapter<K,V> (implements org.springframework.kafka.listener.BatchMessageListener<K,V>)
      • org.springframework.kafka.listener.adapter.FilteringMessageListenerAdapter<K,V> (implements org.springframework.kafka.listener.MessageListener<K,V>)
    • org.springframework.kafka.listener.adapter.AbstractRetryingMessageListenerAdapter<K,V,T>
      • org.springframework.kafka.listener.adapter.RetryingAcknowledgingMessageListenerAdapter<K,V> (implements org.springframework.kafka.listener.AcknowledgingMessageListener<K,V>)
      • org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter<K,V> (implements org.springframework.kafka.listener.MessageListener<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.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.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.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.ConsumerRecordValueCondition<V>
  • org.springframework.kafka.listener.config.ContainerProperties
  • org.springframework.kafka.test.utils.ContainerTestUtils
  • org.springframework.kafka.core.DefaultKafkaConsumerFactory<K,V> (implements org.springframework.kafka.core.ClientIdSuffixAware<K,V>, org.springframework.kafka.core.ConsumerFactory<K,V>)
  • 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.junit.rules.ExternalResource (implements org.junit.rules.TestRule)
    • org.springframework.kafka.test.rule.KafkaEmbedded (implements org.springframework.kafka.test.rule.KafkaRule)
  • org.springframework.kafka.listener.adapter.HandlerAdapter
  • org.springframework.kafka.support.serializer.JsonDeserializer<T> (implements org.apache.kafka.common.serialization.Deserializer<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.Serializer<T>)
  • org.springframework.kafka.annotation.KafkaBootstrapConfiguration
  • org.springframework.kafka.test.assertj.KafkaConditions
  • org.springframework.kafka.support.KafkaHeaders
  • 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.LoggingErrorHandler (implements org.springframework.kafka.listener.ErrorHandler)
  • 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.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.BatchAcknowledgingMessageListener<K,V>, org.springframework.kafka.listener.BatchMessageListener<K,V>)
    • org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter<K,V> (implements org.springframework.kafka.listener.AcknowledgingMessageListener<K,V>, org.springframework.kafka.listener.MessageListener<K,V>)
  • org.springframework.kafka.support.ProducerListenerAdapter<K,V> (implements org.springframework.kafka.support.ProducerListener<K,V>)
    • org.springframework.kafka.support.LoggingProducerListener<K,V>
  • 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.core.ClientIdSuffixAware<K,V>
• org.springframework.kafka.core.ConsumerFactory<K,V>
• org.springframework.kafka.listener.ConsumerSeekAware
• org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback
• org.springframework.kafka.listener.GenericErrorHandler<T>
  • org.springframework.kafka.listener.BatchErrorHandler
  • org.springframework.kafka.listener.ErrorHandler
• org.springframework.kafka.listener.KafkaDataListener<T>
  • org.springframework.kafka.listener.AcknowledgingMessageListener<K,V>
  • org.springframework.kafka.listener.BatchAcknowledgingMessageListener<K,V>
  • org.springframework.kafka.listener.BatchMessageListener<K,V>
  • org.springframework.kafka.listener.GenericAcknowledgingMessageListener<T>
    • org.springframework.kafka.listener.AcknowledgingMessageListener<K,V>
    • org.springframework.kafka.listener.BatchAcknowledgingMessageListener<K,V>
  • org.springframework.kafka.listener.GenericMessageListener<T>
    • org.springframework.kafka.listener.BatchMessageListener<K,V>
    • org.springframework.kafka.listener.MessageListener<K,V>
  • org.springframework.kafka.listener.MessageListener<K,V>
• org.springframework.kafka.annotation.KafkaListenerConfigurer
• org.springframework.kafka.config.KafkaListenerContainerFactory<C>
• org.springframework.kafka.config.KafkaListenerEndpoint
• org.springframework.kafka.core.KafkaOperations<K,V>
• 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)

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.springframework.kafka.listener.AbstractMessageListenerContainer.AckMode