You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/05/23 17:55:04 UTC

[jira] [Work started] (KAFKA-5314) Improve exception handling for state stores

     [ https://issues.apache.org/jira/browse/KAFKA-5314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Work on KAFKA-5314 started by Eno Thereska.
-------------------------------------------
> 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
>             Fix For: 0.11.0.0
>
>
> 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)