Package org.apache.kafka.streams.processor.internals

Interface StreamThread.StateListener

Enclosing class:

StreamThread

public static interface StreamThread.StateListener

Listen to state change events

Method Summary

Modifier and Type	Method	Description
void	onChange(Thread thread, ThreadStateTransitionValidator newState, ThreadStateTransitionValidator oldState)	Called when state changes

Method Detail

onChange

void onChange(Thread thread,
              ThreadStateTransitionValidator newState,
              ThreadStateTransitionValidator oldState)

Called when state changes

Parameters:

thread - thread changing state

newState - current state

oldState - previous state