Package org.springframework.kafka.core
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
-
Constructor Summary
ConstructorsConstructorDescriptionMicrometerConsumerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry) Construct an instance with the provided registry.MicrometerConsumerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry, List<io.micrometer.core.instrument.Tag> tags) Construct an instance with the provided registry and tags. -
Method Summary
Modifier and TypeMethodDescriptionvoidconsumerAdded(String id, org.apache.kafka.clients.consumer.Consumer<K, V> consumer) A new consumer was created.voidconsumerRemoved(String id, org.apache.kafka.clients.consumer.Consumer<K, V> consumer) An existing consumer was removed.
-
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
Description copied from interface:ConsumerFactory.ListenerA new consumer was created.- Specified by:
consumerAddedin interfaceConsumerFactory.Listener<K,V> - Parameters:
id- the consumer id (factory bean name and client.id separated by a period).consumer- the consumer.
-
consumerRemoved
Description copied from interface:ConsumerFactory.ListenerAn existing consumer was removed.- Specified by:
consumerRemovedin interfaceConsumerFactory.Listener<K,V> - Parameters:
id- the consumer id (factory bean name and client.id separated by a period).consumer- the consumer.
-