TaiJuWu commented on code in PR #20635:
URL: https://github.com/apache/kafka/pull/20635#discussion_r2403676711
##########
storage/src/test/java/org/apache/kafka/storage/internals/log/UnifiedLogTest.java:
##########
@@ -513,6 +513,10 @@ public void testDeleteOldSegments() throws IOException {
log.appendAsLeader(records.get(), 0);
}
+ // Bug? Due to log.delete() we can't close the unifiedLog
+ // because we delete log and the memory map is closed.
+ // When we close UnifiedLog, it will check that memory map again and
+ // will throw KafkaStorageException.
Review Comment:
@chia7712 Could you help to take a look this issue?
--
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]
