Package org.springframework.kafka.core
Interface ConsumerFactory.Listener<K,V>
-
- Type Parameters:
K- the key type.V- the value type.
- All Known Implementing Classes:
MicrometerConsumerListener
- Enclosing interface:
- ConsumerFactory<K,V>
public static interface ConsumerFactory.Listener<K,V>Called whenever a consumer is added or removed.- Since:
- 2.5
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default voidconsumerAdded(java.lang.String id, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)A new consumer was created.default voidconsumerRemoved(java.lang.String id, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)An existing consumer was removed.
-