...

• Retryable exceptions
  • StreamThreadNotStartedException: will be thrown when streams thread state is CREATED, the user can retry until to RUNNING.
  • StreamThreadRebalancingException: will be thrown when stream thread is not running and stream state is REBALANCING, the user just retry and wait until rebalance finished (RUNNING).
  • StateStoreMigratedException: will be thrown when state store already closed or state store cannot be found.
• Fatal exceptions
  • StreamThreadNotRunningException: will be thrown when stream thread is not running and stream state is PENDING_SHUTDOWN / NOT_RUNNING / ERROR. The user cannot retry when this exception is thrown.
  • StateStoreNotAvailableException: will be thrown when stream thread is PENDING_SHUTDOWN / NOT_RUNNING / ERROR. The user cannot retry when this exception is thrown.
  • UnknownStateStoreException: will be thrown when passing an unknown state store.

The following is the public methods that users will call to get state store instance or get store values:

• KafkaStreams
  
  • store(storeName, queryableStoreType)

KafkaStreams#store could be throw following exceptions: StreamThreadNotStartedException, StreamThreadRebalancingException, StateStoreMigratedException, KafkaStreamsNotRunningException, StateStoreNotAvailableException, UnknownStateStoreException.

The following is the public methods that users will call to get store values:

• interface ReadOnlyKeyValueStore(class CompositeReadOnlyKeyValueStore)
  • get(key)
  • range(from, to)
  • all()
  • approximateNumEntries()
• interface ReadOnlySessionStore(class CompositeReadOnlySessionStore)
  
  • fetch(key)
  • fetch(from, to)
• interface ReadOnlyWindowStore(class CompositeReadOnlyWindowStore)
  
  • fetch(key, time)

  • fetch(key, from, to)

  • fetch(from, to, fromTime, toTime)
  • all()
  • fetchAll(from, to)
  • @Deprecated fetch(key, timeFrom, timeTo)
  • @Deprecated fetch(from, to, timeFrom, timeTo)
  • @Deprecated fetchAll(timeFrom, timeTo)
• interface KeyValueIterator(class DelegatingPeekingKeyValueIterator)
  
  • next()
  • hasNext()
  • peekNextKey()

All the above methods could be throw following exceptions:

...

 StreamThreadRebalancingException, KafkaStreamsNotRunningException, StateStoreMigratedException, StreamThreadNotRunningException, StateStoreNotAvailableException

Compatibility, Deprecation, and Migration Plan

...