Package org.springframework.kafka.config
Interface StreamsBuilderFactoryBean.Listener
-
- All Known Implementing Classes:
KafkaStreamsMicrometerListener
- Enclosing class:
- StreamsBuilderFactoryBean
public static interface StreamsBuilderFactoryBean.Listener
Called whenever aKafkaStreams
is added or removed.- Since:
- 2.5.3
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default void
streamsAdded(java.lang.String id, org.apache.kafka.streams.KafkaStreams streams)
A newKafkaStreams
was created.default void
streamsRemoved(java.lang.String id, org.apache.kafka.streams.KafkaStreams streams)
An existingKafkaStreams
was removed.
-
-
-
Method Detail
-
streamsAdded
default void streamsAdded(java.lang.String id, org.apache.kafka.streams.KafkaStreams streams)
A newKafkaStreams
was 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 existingKafkaStreams
was removed.- Parameters:
id
- the streams id (factory bean name).streams
- the streams;
-
-