Package org.springframework.kafka.config
Interface StreamsBuilderFactoryBean.Listener
- All Known Implementing Classes:
KafkaStreamsMicrometerListener
- Enclosing class:
- StreamsBuilderFactoryBean
public static interface StreamsBuilderFactoryBean.Listener
Called whenever a
KafkaStreams is added or removed.- Since:
- 2.5.3
-
Method Summary
Modifier and TypeMethodDescriptiondefault voidstreamsAdded(String id, org.apache.kafka.streams.KafkaStreams streams) A newKafkaStreamswas created.default voidstreamsRemoved(String id, org.apache.kafka.streams.KafkaStreams streams) An existingKafkaStreamswas removed.
-
Method Details
-
streamsAdded
A newKafkaStreamswas created.- Parameters:
id- the streams id (factory bean name).streams- the streams;
-
streamsRemoved
An existingKafkaStreamswas removed.- Parameters:
id- the streams id (factory bean name).streams- the streams;
-