Class StreamsRebalancingException

All Implemented Interfaces:

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:
  • Constructor Details

    • StreamsRebalancingException

      public StreamsRebalancingException(String message)
    • StreamsRebalancingException

      public StreamsRebalancingException(String message, Throwable throwable)