Hierarchy For Package org.springframework.kafka.core

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.springframework.kafka.core.ABSwitchCluster (implements java.util.function.Supplier<T>)
  • org.springframework.kafka.core.CleanupConfig
  • org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer<K,V> (implements org.apache.kafka.clients.producer.Producer<K,V>)
  • org.springframework.kafka.core.KafkaAdmin.NewTopics
  • org.springframework.kafka.core.KafkaResourceFactory
    • org.springframework.kafka.core.DefaultKafkaConsumerFactory<K,V> (implements org.springframework.beans.factory.BeanNameAware, org.springframework.kafka.core.ConsumerFactory<K,V>)
    • org.springframework.kafka.core.DefaultKafkaProducerFactory<K,V> (implements org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<E>, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.kafka.core.ProducerFactory<K,V>)
    • org.springframework.kafka.core.KafkaAdmin (implements org.springframework.context.ApplicationContextAware, org.springframework.kafka.core.KafkaAdminOperations, org.springframework.beans.factory.SmartInitializingSingleton)
  • org.springframework.kafka.core.KafkaTemplate<K,V> (implements org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<E>, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.kafka.core.KafkaOperations<K,V>)
    • org.springframework.kafka.core.RoutingKafkaTemplate
  • org.springframework.kafka.core.MicrometerConsumerListener<K,V> (implements org.springframework.kafka.core.ConsumerFactory.Listener<K,V>)
  • org.springframework.kafka.core.MicrometerProducerListener<K,V> (implements org.springframework.kafka.core.ProducerFactory.Listener<K,V>)
  • org.springframework.kafka.core.ProducerFactoryUtils
  • org.springframework.transaction.support.ResourceHolderSupport (implements org.springframework.transaction.support.ResourceHolder)
    • org.springframework.kafka.core.KafkaResourceHolder<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.core.KafkaProducerException

Interface Hierarchy

• org.springframework.kafka.core.ConsumerFactory<K,V>
• org.springframework.kafka.core.ConsumerFactory.Listener<K,V>
• org.springframework.util.concurrent.FailureCallback
  • org.springframework.kafka.core.KafkaFailureCallback<K,V>
    • org.springframework.kafka.core.KafkaSendCallback<K,V> (also extends org.springframework.util.concurrent.ListenableFutureCallback<T>)
  • org.springframework.util.concurrent.ListenableFutureCallback<T> (also extends org.springframework.util.concurrent.SuccessCallback<T>)
    • org.springframework.kafka.core.KafkaSendCallback<K,V> (also extends org.springframework.kafka.core.KafkaFailureCallback<K,V>)
• java.util.function.Function<T,R>
  • org.springframework.kafka.core.ConsumerPostProcessor<K,V>
  • org.springframework.kafka.core.ProducerPostProcessor<K,V>
• org.springframework.kafka.core.KafkaAdminOperations
• 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.kafka.core.KafkaOperations2<K,V>
• org.springframework.kafka.core.ProducerFactory<K,V>
• org.springframework.kafka.core.ProducerFactory.Listener<K,V>
• org.springframework.util.concurrent.SuccessCallback<T>
  • org.springframework.util.concurrent.ListenableFutureCallback<T> (also extends org.springframework.util.concurrent.FailureCallback)
    • org.springframework.kafka.core.KafkaSendCallback<K,V> (also extends org.springframework.kafka.core.KafkaFailureCallback<K,V>)