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
Author:
Artem Bilan, Ivan Ursul, Soby Chacko, Zach Olauson, Nurettin Yilmaz, Denis Washington, Gary Russell, Julien Wittouck, Sanghyeok An, Cédric Schaller, Almog Gavra

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    streamsAdded(String id, org.apache.kafka.streams.KafkaStreams streams)
    A new KafkaStreams was created.
    default void
    streamsRemoved(String id, org.apache.kafka.streams.KafkaStreams streams)
    An existing KafkaStreams was removed.

  • Method Details

    • streamsAdded

      default void streamsAdded(String id, org.apache.kafka.streams.KafkaStreams streams)
      A new KafkaStreams was created.
      Parameters:
      id - the streams id (factory bean name).
      streams - the streams;

    • streamsRemoved

      default void streamsRemoved(String id, org.apache.kafka.streams.KafkaStreams streams)
      An existing KafkaStreams was removed.
      Parameters:
      id - the streams id (factory bean name).
      streams - the streams;