mjsax opened a new pull request #8890: URL: https://github.com/apache/kafka/pull/8890
Ports the test from #8886 to `trunk` -- this should be merged to `2.6` branch. One open question. In `2.6` and `trunk` we rely on the active tasks to wipe out the store if it crashes. However, assume there is a hard JVM crash and we don't call `closeDirty()` the store would not be wiped out. Thus, I am wondering, if we would need to fix this (for both active and standby tasks) and do a check on _startup_ if a local store must be wiped out? The current test passes, as we do a proper cleanup after the exception is thrown. Call for review @guozhangwang @abbccdda ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
