Interface KafkaStreamsContainer.StateChangeWatcher

  • Enclosing class:
    KafkaStreamsContainer

    public static interface KafkaStreamsContainer.StateChangeWatcher
    Watch a KafkaStreams instance for KafkaStreams.State change. By default, a KafkaStreamsContainer.StateChangeWatcher is one time called, i.e. once it is triggered, it has to re-register itself to watch for further changes.
    • Method Detail

      • accept

        default boolean accept​(State newState)
        Should this watcher be called for the given State.
        Parameters:
        newState - the new state of the KafkaStreams instance.
        Returns:
        true if this watcher must be called, false otherwise.