K - the key type.V - the value type.public class MicrometerProducerListener<K,V> extends java.lang.Object implements ProducerFactory.Listener<K,V>
KafkaClientMetrics.| Constructor and Description |
|---|
MicrometerProducerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry)
Construct an instance with the provided registry.
|
MicrometerProducerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry,
java.util.List<io.micrometer.core.instrument.Tag> tags)
Construct an instance with the provided registry and tags.
|
| Modifier and Type | Method and Description |
|---|---|
void |
producerAdded(java.lang.String id,
org.apache.kafka.clients.producer.Producer<K,V> producer)
A new producer was created.
|
void |
producerRemoved(java.lang.String id,
org.apache.kafka.clients.producer.Producer<K,V> producer)
An exsting producer was removed.
|
public MicrometerProducerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry)
meterRegistry - the registry.public MicrometerProducerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry,
java.util.List<io.micrometer.core.instrument.Tag> tags)
meterRegistry - the registry.tags - the tags.public void producerAdded(java.lang.String id,
org.apache.kafka.clients.producer.Producer<K,V> producer)
ProducerFactory.ListenerproducerAdded in interface ProducerFactory.Listener<K,V>id - the producer id (factory bean name and client.id separated by a
period).producer - the producer.public void producerRemoved(java.lang.String id,
org.apache.kafka.clients.producer.Producer<K,V> producer)
ProducerFactory.ListenerproducerRemoved in interface ProducerFactory.Listener<K,V>id - the producer id (factory bean name and client.id separated by a
period).producer - the producer.