Package org.apache.kafka.streams.errors
Class StreamsRebalancingException
- 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.StreamsRebalancingException
-
- All Implemented Interfaces:
Serializable
public class StreamsRebalancingException extends InvalidStateStoreException
Indicates that Kafka Streams is in stateREBALANCING
and thus cannot be queried by default. You can retry to query after the rebalance finished. As an alternative, you can also query (potentially stale) state stores during a rebalance viaStoreQueryParameters.enableStaleStores()
.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description StreamsRebalancingException(String message)
StreamsRebalancingException(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
-
-