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 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:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
StreamsNotStartedException(String message)
StreamsNotStartedException(String message, Throwable throwable)

Method Summary

Methods inherited from class org.apache.kafka.streams.errors.StreamsException

setTaskId, taskId

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

StreamsNotStartedException

public StreamsNotStartedException(String message)

StreamsNotStartedException

public StreamsNotStartedException(String message,
 Throwable throwable)