Class StreamsNotStartedException

All Implemented Interfaces:

public class StreamsNotStartedException extends InvalidStateStoreException
Indicates that Kafka Streams is in state CREATED and thus state stores cannot be queries yet. To query state stores, it's required to first start Kafka Streams via KafkaStreams.start(). You can retry to query the state after the state transitioned to RUNNING.
See Also:
  • Constructor Details

    • StreamsNotStartedException

      public StreamsNotStartedException(String message)
    • StreamsNotStartedException

      public StreamsNotStartedException(String message, Throwable throwable)