KafkaStreams.StateListener (streams 8.1.1-ce API)

Enclosing class:: KafkaStreams

public static interface KafkaStreams.StateListener

Listen to KafkaStreams.State change events.

Method Summary
Modifier and Type
Method
Description
void
onChange(KafkaStreams.State newState, KafkaStreams.State oldState)
Called when state changes.

Method Details
- onChange
  void onChange(KafkaStreams.State newState, KafkaStreams.State oldState)
  Called when state changes.
  Parameters:
  newState - new state
  oldState - previous state