public class StreamsRebalancingException extends InvalidStateStoreException
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()
.Constructor and Description |
---|
StreamsRebalancingException(String message) |
StreamsRebalancingException(String message,
Throwable throwable) |
setTaskId, taskId
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString