Eno Thereska created KAFKA-5314:
-----------------------------------
Summary: Improve exception handling for state stores
Key: KAFKA-5314
URL: https://issues.apache.org/jira/browse/KAFKA-5314
Project: Kafka
Issue Type: Sub-task
Components: streams
Affects Versions: 0.11.0.0
Reporter: Eno Thereska
Assignee: Eno Thereska
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.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
