Package org.apache.kafka.streams.errors
Class StreamsNotStartedException
- java.lang.Object
-
- java.lang.Throwable
-
- java.lang.Exception
-
- java.lang.RuntimeException
-
- org.apache.kafka.common.KafkaException
-
- org.apache.kafka.streams.errors.StreamsException
-
- org.apache.kafka.streams.errors.InvalidStateStoreException
-
- org.apache.kafka.streams.errors.StreamsNotStartedException
-
- All Implemented Interfaces:
Serializable
public class StreamsNotStartedException extends InvalidStateStoreException
Indicates that Kafka Streams is in stateCREATED
and thus state stores cannot be queries yet. To query state stores, it's required to first start Kafka Streams viaKafkaStreams.start()
. You can retry to query the state after the state transitioned toRUNNING
.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description StreamsNotStartedException(String message)
StreamsNotStartedException(String message, Throwable throwable)
-
Method Summary
-
Methods inherited from class java.lang.Throwable
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString
-
-