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 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;