org.apache.kafka.streams

Interface KafkaStreams.StateListener

Enclosing class:

KafkaStreams

public static interface KafkaStreams.StateListener

Listen to KafkaStreams.State change events.

Method Summary

Modifier and Type	Method and Description
void	onChange(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 state

oldState - previous state