You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/13 16:49:00 UTC

[jira] [Updated] (KAFKA-20777) StagedMergeIterator throws IllegalStateException instead of InvalidStateStoreException when used after store close

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

Matthias J. Sax updated KAFKA-20777:
------------------------------------
    Issue Type: Bug  (was: Improvement)

> StagedMergeIterator throws IllegalStateException instead of InvalidStateStoreException when used after store close
> ------------------------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-20777
>                 URL: https://issues.apache.org/jira/browse/KAFKA-20777
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams
>            Reporter: Alan Lau
>            Assignee: Alan Lau
>            Priority: Trivial
>
> When transactional state stores are enabled (enable.transactional.statestores=true), an open StagedMergeIterator that is used after the store is closed throws java.lang.IllegalStateException("Iterator has already been closed.") from StagedMergeIterator.hasNext(), for consistency with the other managed store iterators (e.g. RocksDbIterator), it should throw InvalidStateStoreException.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)