Description
RocksDbStore.java throws a mix of exceptions like StreamsException and ProcessorStateException. That needs to be made consistent.
Also the exceptions thrown are not documented in the KeyValueStore interface.
All the stores (RocksDb, InMemory) need to have consistent exception handling.
Today a store error is fatal and halts the stream thread that is processing the exceptions. We could explore alternatives, like haling part of the topology that passes through that faulty store, i.e., failing tasks, not the entire thread.
Attachments
Issue Links
- links to