Class MicrometerConsumerListener<K,V>

java.lang.Object
org.springframework.kafka.core.MicrometerConsumerListener<K,V>
Type Parameters:
K - the key type.
V - the value type.
All Implemented Interfaces:
ConsumerFactory.Listener<K,V>

public class MicrometerConsumerListener<K,V> extends Object implements ConsumerFactory.Listener<K,V>
A consumer factory listener that manages KafkaClientMetrics.
Since:
2.5
Author:
Gary Russell
  • Constructor Details

    • MicrometerConsumerListener

      public MicrometerConsumerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry)
      Construct an instance with the provided registry.
      Parameters:
      meterRegistry - the registry.
    • MicrometerConsumerListener

      public MicrometerConsumerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry, List<io.micrometer.core.instrument.Tag> tags)
      Construct an instance with the provided registry and tags.
      Parameters:
      meterRegistry - the registry.
      tags - the tags.
  • Method Details

    • consumerAdded

      public void consumerAdded(String id, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
      Description copied from interface: ConsumerFactory.Listener
      A new consumer was created.
      Specified by:
      consumerAdded in interface ConsumerFactory.Listener<K,V>
      Parameters:
      id - the consumer id (factory bean name and client.id separated by a period).
      consumer - the consumer.
    • consumerRemoved

      public void consumerRemoved(String id, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
      Description copied from interface: ConsumerFactory.Listener
      An existing consumer was removed.
      Specified by:
      consumerRemoved in interface ConsumerFactory.Listener<K,V>
      Parameters:
      id - the consumer id (factory bean name and client.id separated by a period).
      consumer - the consumer.