public class StreamsNotStartedException extends InvalidStateStoreException
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
.Constructor and Description |
---|
StreamsNotStartedException(java.lang.String message) |
StreamsNotStartedException(java.lang.String message,
java.lang.Throwable throwable) |