You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Alan Lau (Jira)" <ji...@apache.org> on 2026/07/06 17:16:00 UTC
[jira] [Created] (KAFKA-20777) StagedMergeIterator throws IllegalStateException instead of InvalidStateStoreException when used after store close
Alan Lau created KAFKA-20777:
--------------------------------
Summary: 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: Improvement
Components: streams
Reporter: Alan Lau
Assignee: Alan Lau
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)