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)
