Package org.springframework.kafka.config

Interface StreamsBuilderFactoryBean.Listener

    • 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 new KafkaStreams was created.
      default void streamsRemoved​(java.lang.String id, org.apache.kafka.streams.KafkaStreams streams)
      An existing KafkaStreams was removed.

    • Method Detail

      • streamsAdded

        default void streamsAdded​(java.lang.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​(java.lang.String id,
                            org.apache.kafka.streams.KafkaStreams streams)
        An existing KafkaStreams was removed.
        Parameters:
        id - the streams id (factory bean name).
        streams - the streams;