Class CompositeStateListener

  • All Implemented Interfaces:
    KafkaStreamsContainerAware, org.apache.kafka.streams.KafkaStreams.StateListener

    public class CompositeStateListener
    extends Object
    implements org.apache.kafka.streams.KafkaStreams.StateListener, KafkaStreamsContainerAware
    A KafkaStreams.StateListener that delegates to one or more KafkaStreams.StateListener in order.
    • Method Detail

      • addListener

        public CompositeStateListener addListener​(org.apache.kafka.streams.KafkaStreams.StateListener listener)
      • onChange

        public void onChange​(org.apache.kafka.streams.KafkaStreams.State newState,
                             org.apache.kafka.streams.KafkaStreams.State oldState)
        Specified by:
        onChange in interface org.apache.kafka.streams.KafkaStreams.StateListener