Hierarchy For All Packages

Package Hierarchies:

• io.micronaut.configuration.kafka,
• io.micronaut.configuration.kafka.admin,
• io.micronaut.configuration.kafka.annotation,
• io.micronaut.configuration.kafka.bind,
• io.micronaut.configuration.kafka.bind.batch,
• io.micronaut.configuration.kafka.config,
• io.micronaut.configuration.kafka.convert,
• io.micronaut.configuration.kafka.embedded,
• io.micronaut.configuration.kafka.exceptions,
• io.micronaut.configuration.kafka.executor,
• io.micronaut.configuration.kafka.health,
• io.micronaut.configuration.kafka.intercept,
• io.micronaut.configuration.kafka.metrics,
• io.micronaut.configuration.kafka.processor,
• io.micronaut.configuration.kafka.scope,
• io.micronaut.configuration.kafka.serde,
• io.micronaut.configuration.kafka.streams,
• io.micronaut.configuration.kafka.tracing

Class Hierarchy

• java.lang.Object
  • io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration<K,V>
    • io.micronaut.configuration.kafka.config.AbstractKafkaConsumerConfiguration<K,V>
      • io.micronaut.configuration.kafka.config.DefaultKafkaConsumerConfiguration<K,V>
      • io.micronaut.configuration.kafka.config.KafkaConsumerConfiguration<K,V>
    • io.micronaut.configuration.kafka.config.AbstractKafkaProducerConfiguration<K,V>
      • io.micronaut.configuration.kafka.config.DefaultKafkaProducerConfiguration<K,V>
      • io.micronaut.configuration.kafka.config.KafkaProducerConfiguration<K,V>
    • io.micronaut.configuration.kafka.streams.AbstractKafkaStreamsConfiguration<K,V>
      • io.micronaut.configuration.kafka.streams.DefaultKafkaStreamsConfiguration<K,V>
      • io.micronaut.configuration.kafka.streams.KafkaStreamsConfiguration<K,V>
    • io.micronaut.configuration.kafka.config.KafkaDefaultConfiguration
  • io.micronaut.configuration.kafka.admin.AdminClientFactory
  • io.micronaut.configuration.kafka.bind.batch.BatchConsumerRecordsBinderRegistry (implements io.micronaut.core.bind.ArgumentBinderRegistry<S>)
  • io.micronaut.configuration.kafka.serde.CompositeSerdeRegistry (implements io.micronaut.configuration.kafka.serde.SerdeRegistry)
  • io.micronaut.configuration.kafka.executor.ConsumerExecutorServiceConfig
  • io.micronaut.configuration.kafka.metrics.ConsumerKafkaMetricsReporter
  • io.micronaut.configuration.kafka.bind.ConsumerRecordBinderRegistry (implements io.micronaut.core.bind.ArgumentBinderRegistry<S>)
  • io.micronaut.configuration.kafka.exceptions.DefaultKafkaListenerExceptionHandler (implements io.micronaut.configuration.kafka.exceptions.KafkaListenerExceptionHandler)
  • io.micronaut.configuration.kafka.serde.JsonSerde<T> (implements org.apache.kafka.common.serialization.Deserializer<T>, org.apache.kafka.common.serialization.Serde<T>, org.apache.kafka.common.serialization.Serializer<T>)
  • io.micronaut.configuration.kafka.serde.JsonSerdeRegistry (implements io.micronaut.configuration.kafka.serde.SerdeRegistry)
  • io.micronaut.configuration.kafka.bind.KafkaBodyBinder<T> (implements io.micronaut.configuration.kafka.bind.AnnotatedConsumerRecordBinder<A,T>)
  • io.micronaut.configuration.kafka.annotation.KafkaClient.Acknowledge
  • io.micronaut.configuration.kafka.intercept.KafkaClientIntroductionAdvice (implements java.lang.AutoCloseable, io.micronaut.aop.MethodInterceptor<T,R>)
  • io.micronaut.configuration.kafka.scope.KafkaClientScope (implements io.micronaut.context.scope.CustomScope<A>, io.micronaut.context.LifeCycle<T>, io.micronaut.configuration.kafka.ProducerRegistry)
  • io.micronaut.configuration.kafka.KafkaConsumerFactory
  • io.micronaut.configuration.kafka.metrics.KafkaConsumerMetrics (implements io.micronaut.context.event.BeanCreatedEventListener<T>)
  • io.micronaut.configuration.kafka.processor.KafkaConsumerProcessor (implements java.lang.AutoCloseable, io.micronaut.configuration.kafka.ConsumerRegistry, io.micronaut.context.processor.ExecutableMethodProcessor<A>)
  • io.micronaut.configuration.kafka.tracing.KafkaConsumerTracingInstrumentation (implements io.micronaut.context.event.BeanCreatedEventListener<T>)
  • io.micronaut.configuration.kafka.bind.KafkaDefaultBinder<T> (implements io.micronaut.configuration.kafka.bind.ConsumerRecordBinder<T>)
  • io.micronaut.configuration.kafka.embedded.KafkaEmbedded (implements java.lang.AutoCloseable, io.micronaut.context.event.BeanCreatedEventListener<T>)
  • io.micronaut.configuration.kafka.embedded.KafkaEmbeddedConfiguration (implements io.micronaut.core.util.Toggleable)
  • io.micronaut.configuration.kafka.bind.KafkaHeaderBinder<T> (implements io.micronaut.configuration.kafka.bind.AnnotatedConsumerRecordBinder<A,T>)
  • io.micronaut.configuration.kafka.convert.KafkaHeaderConverter (implements io.micronaut.core.convert.TypeConverter<S,T>)
  • io.micronaut.configuration.kafka.KafkaHeaders (implements io.micronaut.messaging.MessageHeaders)
  • io.micronaut.configuration.kafka.bind.KafkaHeadersBinder (implements io.micronaut.configuration.kafka.bind.TypedConsumerRecordBinder<T>)
  • io.micronaut.configuration.kafka.health.KafkaHealthIndicator (implements io.micronaut.management.health.indicator.HealthIndicator)
  • io.micronaut.configuration.kafka.bind.KafkaKeyBinder<T> (implements io.micronaut.configuration.kafka.bind.AnnotatedConsumerRecordBinder<A,T>)
  • io.micronaut.configuration.kafka.bind.KafkaMessagingBodyBinder<T> (implements io.micronaut.configuration.kafka.bind.AnnotatedConsumerRecordBinder<A,T>)
  • io.micronaut.configuration.kafka.KafkaProducerFactory
  • io.micronaut.configuration.kafka.metrics.KafkaProducerMetrics (implements io.micronaut.context.event.BeanCreatedEventListener<T>)
  • io.micronaut.configuration.kafka.tracing.KafkaProducerTracingInstrumentation (implements io.micronaut.context.event.BeanCreatedEventListener<T>)
  • io.micronaut.configuration.kafka.streams.KafkaStreamsFactory (implements java.io.Closeable)
  • io.micronaut.configuration.kafka.metrics.ProducerKafkaMetricsReporter
  • org.apache.kafka.streams.StreamsBuilder
    • io.micronaut.configuration.kafka.streams.ConfiguredStreamBuilder
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • io.micronaut.messaging.exceptions.MessagingException
          • io.micronaut.messaging.exceptions.MessageListenerException
            • io.micronaut.configuration.kafka.exceptions.KafkaListenerException

Interface Hierarchy

• io.micronaut.configuration.kafka.Acknowledgement
  • io.micronaut.configuration.kafka.KafkaAcknowledgement (also extends io.micronaut.messaging.Acknowledgement)
• io.micronaut.messaging.Acknowledgement
  • io.micronaut.configuration.kafka.KafkaAcknowledgement (also extends io.micronaut.configuration.kafka.Acknowledgement)
• io.micronaut.core.bind.ArgumentBinder<T,S>
  • io.micronaut.configuration.kafka.bind.ConsumerRecordBinder<T>
    • io.micronaut.configuration.kafka.bind.AnnotatedConsumerRecordBinder<A,T>
    • io.micronaut.configuration.kafka.bind.TypedConsumerRecordBinder<T> (also extends io.micronaut.core.bind.TypeArgumentBinder<T,S>)
  • io.micronaut.core.bind.TypeArgumentBinder<T,S>
    • io.micronaut.configuration.kafka.bind.TypedConsumerRecordBinder<T> (also extends io.micronaut.configuration.kafka.bind.ConsumerRecordBinder<T>)
• io.micronaut.configuration.kafka.ConsumerAware<K,V>
  • io.micronaut.configuration.kafka.KafkaConsumerAware<K,V>
• io.micronaut.configuration.kafka.ConsumerRegistry
• io.micronaut.core.exceptions.ExceptionHandler<T>
  • io.micronaut.configuration.kafka.exceptions.KafkaListenerExceptionHandler
• io.micronaut.core.order.Ordered
  • io.micronaut.configuration.kafka.serde.SerdeRegistry
• io.micronaut.configuration.kafka.ProducerRegistry
  • io.micronaut.configuration.kafka.KafkaProducerRegistry

Annotation Type Hierarchy

• io.micronaut.configuration.kafka.annotation.KafkaKey (implements java.lang.annotation.Annotation)
• io.micronaut.configuration.kafka.annotation.Topic (implements java.lang.annotation.Annotation)
• io.micronaut.configuration.kafka.annotation.KafkaClient (implements java.lang.annotation.Annotation)
• io.micronaut.configuration.kafka.annotation.Topics (implements java.lang.annotation.Annotation)
• io.micronaut.configuration.kafka.annotation.KafkaListener (implements java.lang.annotation.Annotation)

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • io.micronaut.configuration.kafka.annotation.OffsetReset
    • io.micronaut.configuration.kafka.annotation.OffsetStrategy