reactor.kafka.receiver

Class MicrometerConsumerListener

java.lang.Object

reactor.kafka.receiver.MicrometerConsumerListener

All Implemented Interfaces:

ReceiverOptions.ConsumerListener

public class MicrometerConsumerListener
extends Object
implements ReceiverOptions.ConsumerListener

A consumer listener that manages KafkaClientMetrics.

Since:

1.3.17

Constructor Summary

Constructors

Constructor and Description
MicrometerConsumerListener(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 Type	Method and Description
void	consumerAdded(String id, org.apache.kafka.clients.consumer.Consumer<?,?> consumer) A new consumer was created.
void	consumerRemoved(String id, org.apache.kafka.clients.consumer.Consumer<?,?> consumer) An existing consumer was removed.

Methods inherited from class java.lang.Object

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

Constructor Detail

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 Detail

consumerAdded

public void consumerAdded(String id,
                          org.apache.kafka.clients.consumer.Consumer<?,?> consumer)

Description copied from interface: ReceiverOptions.ConsumerListener

A new consumer was created.

Specified by:

consumerAdded in interface ReceiverOptions.ConsumerListener

Parameters:

id - the consumer id.

consumer - the consumer.

consumerRemoved

public void consumerRemoved(String id,
                            org.apache.kafka.clients.consumer.Consumer<?,?> consumer)

Description copied from interface: ReceiverOptions.ConsumerListener

An existing consumer was removed.

Specified by:

consumerRemoved in interface ReceiverOptions.ConsumerListener

Parameters:

id - the consumer id.

consumer - the consumer.