THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
org.apache.kafka.streams.errors.StateStoreMigratedException
org.apache.kafka.streams.errors.StateStoreClosedException
StateStoreMigratedException
...
used
...
in
...
the
...
QueryableStoreProvider,
...
StreamThreadStateStoreProvider
...
and WrappingStoreProvider. The state store must be rediscovered when state store was migrated. The user can catch StateStoreMigratedException and wait until the store recreation finished.
StateStoreClosedException use for internal WrappingStoreProvider. The user can catch the exception and just wait until the store recreation finished.
Compatibility, Deprecation, and Migration Plan
...