public static interface StreamsBuilderFactoryBean.Listener
KafkaStreams is added or removed.| Modifier and Type | Method and Description |
|---|---|
default void |
streamsAdded(java.lang.String id,
org.apache.kafka.streams.KafkaStreams streams)
A new
KafkaStreams was created. |
default void |
streamsRemoved(java.lang.String id,
org.apache.kafka.streams.KafkaStreams streams)
An existing
KafkaStreams was removed. |
default void streamsAdded(java.lang.String id,
org.apache.kafka.streams.KafkaStreams streams)
KafkaStreams was created.id - the streams id (factory bean name).streams - the streams;default void streamsRemoved(java.lang.String id,
org.apache.kafka.streams.KafkaStreams streams)
KafkaStreams was removed.id - the streams id (factory bean name).streams - the streams;