alanlau28 opened a new pull request, #22797:
URL: https://github.com/apache/kafka/pull/22797
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 is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
