[ https://issues.apache.org/jira/browse/KAFKA-9770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073468#comment-17073468 ]
Bruno Cadonna commented on KAFKA-9770: -------------------------------------- I will keep this ticket open until you will have tried to cherry-pick the fix to 2.5 after the upcoming release. > Caching State Store does not Close Underlying State Store When Exception is > Thrown During Flushing > -------------------------------------------------------------------------------------------------- > > Key: KAFKA-9770 > URL: https://issues.apache.org/jira/browse/KAFKA-9770 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 2.0.0 > Reporter: Bruno Cadonna > Assignee: Bruno Cadonna > Priority: Major > Fix For: 2.6.0 > > > When a caching state store is closed it calls its {{flush()}} method. If > {{flush()}} throws an exception the underlying state store is not closed. -- This message was sent by Atlassian Jira (v8.3.4#803005)