Package org.apache.kafka.streams
Interface KafkaStreams.StateListener
-
- Enclosing class:
- KafkaStreams
public static interface KafkaStreams.StateListenerListen toKafkaStreams.Statechange events.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidonChange(KafkaStreams.State newState, KafkaStreams.State oldState)Called when state changes.
-
-
-
Method Detail
-
onChange
void onChange(KafkaStreams.State newState, KafkaStreams.State oldState)
Called when state changes.- Parameters:
newState- new stateoldState- previous state
-
-