reactor.kafka.sender

Class MicrometerProducerListener

java.lang.Object

reactor.kafka.sender.MicrometerProducerListener

All Implemented Interfaces:

SenderOptions.ProducerListener

public class MicrometerProducerListener
extends Object
implements SenderOptions.ProducerListener

A producer listener that manages KafkaClientMetrics.

Since:

1.3.17

Constructor Summary

Constructors

Constructor and Description
MicrometerProducerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry) Construct an instance with the provided registry.
MicrometerProducerListener(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 Type	Method and Description
void	producerAdded(String id, org.apache.kafka.clients.producer.Producer<?,?> producer) A new producer was created.
void	producerRemoved(String id, org.apache.kafka.clients.producer.Producer<?,?> producer) An existing producer was removed.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MicrometerProducerListener

public MicrometerProducerListener(io.micrometer.core.instrument.MeterRegistry meterRegistry)

Construct an instance with the provided registry.

Parameters:

meterRegistry - the registry.

MicrometerProducerListener

public MicrometerProducerListener(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 Detail

producerAdded

public void producerAdded(String id,
                          org.apache.kafka.clients.producer.Producer<?,?> producer)

Description copied from interface: SenderOptions.ProducerListener

A new producer was created.

Specified by:

producerAdded in interface SenderOptions.ProducerListener

Parameters:

id - the producer id (factory bean name and client.id separated by a period).

producer - the producer.

producerRemoved

public void producerRemoved(String id,
                            org.apache.kafka.clients.producer.Producer<?,?> producer)

Description copied from interface: SenderOptions.ProducerListener

An existing producer was removed.

Specified by:

producerRemoved in interface SenderOptions.ProducerListener

Parameters:

id - the producer id (factory bean name and client.id separated by a period).

producer - the producer.