Class MonitoringStreamsTask

  • All Implemented Interfaces:
    Runnable

    public final class MonitoringStreamsTask
    extends Thread
    Task for reporting KafkaStreams state changes.