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.event,
• io.micronaut.configuration.kafka.exceptions,
• io.micronaut.configuration.kafka.executor,
• io.micronaut.configuration.kafka.health,
• io.micronaut.configuration.kafka.metrics,
• io.micronaut.configuration.kafka.metrics.builder,
• io.micronaut.configuration.kafka.reactor,
• io.micronaut.configuration.kafka.retry,
• io.micronaut.configuration.kafka.seek,
• io.micronaut.configuration.kafka.serde,
• io.micronaut.configuration.kafka.streams,
• io.micronaut.configuration.kafka.streams.event,
• io.micronaut.configuration.kafka.streams.health,
• io.micronaut.configuration.kafka.streams.health.serde,
• io.micronaut.configuration.kafka.streams.metrics,
• io.micronaut.configuration.kafka.tracing.brave,
• io.micronaut.kafka.info,
• io.micronaut.testcontainers.kafka

Class Hierarchy

• java.lang.Object
  • io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration<K,V> (implements io.micronaut.core.util.Toggleable)
    • 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> (implements io.micronaut.core.naming.Named)
      • 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.metrics.AbstractKafkaMetrics<T>
    • io.micronaut.configuration.kafka.metrics.KafkaConsumerMetrics (implements io.micronaut.context.event.BeanCreatedEventListener<T>)
    • io.micronaut.configuration.kafka.metrics.KafkaProducerMetrics (implements io.micronaut.context.event.BeanCreatedEventListener<T>)
    • io.micronaut.configuration.kafka.streams.metrics.KafkaStreamsMetrics (implements io.micronaut.context.event.BeanCreatedEventListener<T>)
  • io.micronaut.configuration.kafka.metrics.AbstractKafkaMetricsReporter (implements java.io.Closeable, io.micrometer.core.instrument.binder.MeterBinder, org.apache.kafka.common.metrics.MetricsReporter)
    • io.micronaut.configuration.kafka.metrics.ConsumerKafkaMetricsReporter
    • io.micronaut.configuration.kafka.streams.metrics.KafkaStreamsMetricsReporter
    • io.micronaut.configuration.kafka.metrics.ProducerKafkaMetricsReporter
  • io.micronaut.module.info.AbstractMicronautModuleInfo (implements io.micronaut.module.info.MicronautModuleInfo)
    • io.micronaut.kafka.info.MicronautKafkaModuleInfo
    • io.micronaut.kafka.info.MicronautKafkaStreamsModuleInfo
  • io.micronaut.configuration.kafka.admin.AdminClientFactory
  • io.micronaut.configuration.kafka.bind.batch.BatchConsumerRecordsBinderRegistry (implements io.micronaut.core.bind.ArgumentBinderRegistry<S>)
  • io.micronaut.configuration.kafka.tracing.brave.BraveKafkaConsumerTracingInstrumentation (implements io.micronaut.context.event.BeanCreatedEventListener<T>)
  • io.micronaut.configuration.kafka.tracing.brave.BraveKafkaProducerTracingInstrumentation (implements io.micronaut.context.event.BeanCreatedEventListener<T>)
  • io.micronaut.configuration.kafka.tracing.brave.BraveKafkaTracingFactory
  • io.micronaut.configuration.kafka.serde.CompositeSerdeRegistry (implements io.micronaut.configuration.kafka.serde.SerdeRegistry)
  • io.micronaut.configuration.kafka.executor.ConsumerExecutorServiceConfig
  • io.micronaut.configuration.kafka.bind.ConsumerRecordBinderRegistry (implements io.micronaut.core.bind.ArgumentBinderRegistry<S>)
  • io.micronaut.configuration.kafka.retry.DefaultConditionalRetryBehaviourHandler (implements io.micronaut.configuration.kafka.retry.ConditionalRetryBehaviourHandler)
  • io.micronaut.configuration.kafka.exceptions.DefaultKafkaListenerExceptionHandler (implements io.micronaut.configuration.kafka.exceptions.KafkaListenerExceptionHandler)
  • io.micronaut.configuration.kafka.config.DefaultKafkaListenerExceptionHandlerConfigurationProperties (implements io.micronaut.configuration.kafka.config.DefaultKafkaListenerExceptionHandlerConfiguration)
  • io.micronaut.configuration.kafka.health.DefaultNetworkClientCreator (implements io.micronaut.configuration.kafka.health.NetworkClientCreator)
  • io.micronaut.configuration.kafka.DefaultProducerFactory (implements io.micronaut.configuration.kafka.ProducerFactory)
  • java.util.EventObject (implements java.io.Serializable)
    • io.micronaut.context.event.ApplicationEvent
      • io.micronaut.configuration.kafka.event.AbstractKafkaApplicationEvent<T>
        • io.micronaut.configuration.kafka.streams.event.AbstractKafkaStreamsEvent
          • io.micronaut.configuration.kafka.streams.event.AfterKafkaStreamsStart
          • io.micronaut.configuration.kafka.streams.event.BeforeKafkaStreamStart
        • io.micronaut.configuration.kafka.event.KafkaConsumerStartedPollingEvent
        • io.micronaut.configuration.kafka.event.KafkaConsumerSubscribedEvent
  • io.micronaut.configuration.kafka.streams.InteractiveQueryService
  • io.micronaut.configuration.kafka.serde.JsonObjectSerde<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.testcontainers.kafka.Kafka
  • io.micronaut.configuration.kafka.annotation.KafkaClient.Acknowledge
  • io.micronaut.configuration.kafka.KafkaConsumerFactory
  • io.micronaut.configuration.kafka.bind.KafkaDefaultBinder<T> (implements io.micronaut.configuration.kafka.bind.ConsumerRecordBinder<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.config.KafkaHealthConfigurationProperties (implements io.micronaut.configuration.kafka.config.KafkaHealthConfiguration)
  • io.micronaut.configuration.kafka.health.KafkaHealthIndicator (implements org.apache.kafka.common.ClusterResourceListener, 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.KafkaMessage<K,V>
  • io.micronaut.configuration.kafka.KafkaMessage.Builder<K,V>
  • io.micronaut.configuration.kafka.bind.KafkaMessageHeaderBinder<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.metrics.builder.KafkaMetricMeterTypeBuilder
  • io.micronaut.configuration.kafka.admin.KafkaNewTopics
  • io.micronaut.configuration.kafka.bind.KafkaPartitionBinder<T> (implements io.micronaut.configuration.kafka.bind.AnnotatedConsumerRecordBinder<A,T>)
  • io.micronaut.configuration.kafka.KafkaProducerFactory (implements io.micronaut.configuration.kafka.ProducerRegistry, io.micronaut.configuration.kafka.TransactionalProducerRegistry)
  • io.micronaut.configuration.kafka.reactor.KafkaReactorUtil
  • io.micronaut.configuration.kafka.streams.KafkaStreamsFactory (implements java.io.Closeable)
  • io.micronaut.configuration.kafka.streams.health.KafkaStreamsHealth (implements io.micronaut.management.health.indicator.HealthIndicator)
  • org.apache.kafka.streams.StreamsBuilder
    • io.micronaut.configuration.kafka.streams.ConfiguredStreamBuilder (implements io.micronaut.core.naming.Named)
  • io.micronaut.configuration.kafka.streams.health.serde.TaskIdSerde (implements io.micronaut.serde.Serde<T>)
  • 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.messaging.Acknowledgement
  • io.micronaut.configuration.kafka.KafkaAcknowledgement
• 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.retry.ConditionalRetryBehaviourHandler
• io.micronaut.configuration.kafka.ConsumerAware<K,V>
• io.micronaut.configuration.kafka.ConsumerRegistry
• io.micronaut.configuration.kafka.ConsumerSeekAware
• io.micronaut.core.exceptions.ExceptionHandler<T>
  • io.micronaut.configuration.kafka.exceptions.KafkaListenerExceptionHandler
• java.lang.Iterable<T>
  • io.micronaut.configuration.kafka.seek.KafkaSeekOperations
• io.micronaut.configuration.kafka.seek.KafkaSeeker
• io.micronaut.configuration.kafka.seek.KafkaSeekOperation
• io.micronaut.configuration.kafka.health.NetworkClientCreator
• io.micronaut.core.order.Ordered
  • io.micronaut.configuration.kafka.serde.SerdeRegistry
• io.micronaut.configuration.kafka.ProducerFactory
• io.micronaut.configuration.kafka.ProducerRegistry
• io.micronaut.core.util.Toggleable
  • io.micronaut.configuration.kafka.config.DefaultKafkaListenerExceptionHandlerConfiguration
  • io.micronaut.configuration.kafka.config.KafkaHealthConfiguration
• io.micronaut.configuration.kafka.TransactionalProducerRegistry

Annotation Interface Hierarchy

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

Enum Class Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)
    • io.micronaut.configuration.kafka.retry.ConditionalRetryBehaviourHandler.ConditionalRetryBehaviour
    • io.micronaut.configuration.kafka.annotation.ErrorStrategyValue
    • io.micronaut.configuration.kafka.seek.KafkaSeekOperation.OffsetType
    • io.micronaut.configuration.kafka.metrics.builder.MeterType
    • io.micronaut.configuration.kafka.annotation.OffsetReset
    • io.micronaut.configuration.kafka.annotation.OffsetStrategy