Package io.quarkus.micrometer.deployment.binder

Class KafkaBinderProcessor

java.lang.Object
io.quarkus.micrometer.deployment.binder.KafkaBinderProcessor
public class KafkaBinderProcessor extends Object
Add support for Kafka Producer, Consumer and Streams instrumentation. Note that various bits of support may not be present at deploy time. Avoid referencing classes that in turn import optional dependencies.

  • Field Details

    • KAFKA_CONSUMER_CLASS_NAME

      static final String KAFKA_CONSUMER_CLASS_NAME
      See Also:

    • KAFKA_CONSUMER_CLASS_CLASS

      static final Class<?> KAFKA_CONSUMER_CLASS_CLASS

    • KAFKA_STREAMS_CLASS_NAME

      static final String KAFKA_STREAMS_CLASS_NAME
      See Also:

    • KAFKA_STREAMS_CLASS_CLASS

      static final Class<?> KAFKA_STREAMS_CLASS_CLASS

    • KAFKA_EVENT_CONSUMER_CLASS_NAME

      static final String KAFKA_EVENT_CONSUMER_CLASS_NAME
      See Also:

    • KAFKA_STREAMS_METRICS_PRODUCER_CLASS_NAME

      static final String KAFKA_STREAMS_METRICS_PRODUCER_CLASS_NAME
      See Also:

  • Constructor Details

    • KafkaBinderProcessor

      public KafkaBinderProcessor()

  • Method Details

    • createCDIEventConsumer

      io.quarkus.arc.deployment.AdditionalBeanBuildItem createCDIEventConsumer()

    • createKafkaStreamsEventObserver

      io.quarkus.arc.deployment.AdditionalBeanBuildItem createKafkaStreamsEventObserver()