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 state REBALANCING 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 via StoreQueryParameters.enableStaleStores().

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
StreamsRebalancingException(String message)
StreamsRebalancingException(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

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

StreamsRebalancingException

public StreamsRebalancingException(String message)

StreamsRebalancingException

public StreamsRebalancingException(String message,
 Throwable throwable)