Class StreamsStoppedException

All Implemented Interfaces:

public class StreamsStoppedException extends InvalidStateStoreException
Indicates that Kafka Streams is in a terminating or terminal state, such as KafkaStreams.State.PENDING_SHUTDOWN,KafkaStreams.State.PENDING_ERROR,KafkaStreams.State.NOT_RUNNING, or KafkaStreams.State.ERROR. This Streams instance will need to be discarded and replaced before it can serve queries. The caller may wish to query a different instance.
See Also:
  • Constructor Details

    • StreamsStoppedException

      public StreamsStoppedException(String message)
    • StreamsStoppedException

      public StreamsStoppedException(String message, Throwable throwable)