[ https://issues.apache.org/jira/browse/KAFKA-9770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073222#comment-17073222 ]
John Roesler commented on KAFKA-9770: ------------------------------------- I can't cherry-pick to the 2.5 branch until the 2.5.0 release is complete, and the older ones don't have a clean cherry-pick, so I'm just going to leave it in for 2.6.0 right now. > 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)