Package org.springframework.kafka.config
Interface StreamsBuilderFactoryBean.Listener
-
- All Known Implementing Classes:
KafkaStreamsMicrometerListener
- Enclosing class:
- StreamsBuilderFactoryBean
public static interface StreamsBuilderFactoryBean.ListenerCalled whenever aKafkaStreamsis added or removed.- Since:
- 2.5.3
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default voidstreamsAdded(java.lang.String id, org.apache.kafka.streams.KafkaStreams streams)A newKafkaStreamswas created.default voidstreamsRemoved(java.lang.String id, org.apache.kafka.streams.KafkaStreams streams)An existingKafkaStreamswas removed.
-
-
-
Method Detail
-
streamsAdded
default void streamsAdded(java.lang.String id, org.apache.kafka.streams.KafkaStreams streams)A newKafkaStreamswas created.- Parameters:
id- the streams id (factory bean name).streams- the streams;
-
streamsRemoved
default void streamsRemoved(java.lang.String id, org.apache.kafka.streams.KafkaStreams streams)An existingKafkaStreamswas removed.- Parameters:
id- the streams id (factory bean name).streams- the streams;
-
-