reactor.kafka.receiver

Interface ReceiverOptions.ConsumerListener

All Known Implementing Classes:

MicrometerConsumerListener

Enclosing interface:

ReceiverOptions<K,V>

public static interface ReceiverOptions.ConsumerListener

Called whenever a consumer is added or removed.

Since:

1.3.17

Method Summary

Modifier and Type	Method and Description
default void	consumerAdded(String id, org.apache.kafka.clients.consumer.Consumer<?,?> consumer) A new consumer was created.
default void	consumerRemoved(String id, org.apache.kafka.clients.consumer.Consumer<?,?> consumer) An existing consumer was removed.

Method Detail

consumerAdded

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

A new consumer was created.

Parameters:

id - the consumer id.

consumer - the consumer.

consumerRemoved

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

An existing consumer was removed.

Parameters:

id - the consumer id.

consumer - the consumer.