diff --git a/storage/src/test/java/org/apache/kafka/storage/internals/log/RemoteIndexCacheTest.java b/storage/src/test/java/org/apache/kafka/storage/internals/log/RemoteIndexCacheTest.java index b1480d36775..6111cb783a4 100644 --- a/storage/src/test/java/org/apache/kafka/storage/internals/log/RemoteIndexCacheTest.java +++ b/storage/src/test/java/org/apache/kafka/storage/internals/log/RemoteIndexCacheTest.java @@ -331,6 +331,18 @@ public class RemoteIndexCacheTest { verify(cacheEntry.offsetIndex()).renameTo(any(File.class)); verify(cacheEntry.txnIndex()).renameTo(any(File.class)); + // wait until the delete method is invoked + TestUtils.waitForCondition(() -> { + try { + verify(cacheEntry.timeIndex()).deleteIfExists(); + verify(cacheEntry.offsetIndex()).deleteIfExists(); + verify(cacheEntry.txnIndex()).deleteIfExists(); + return true; + } catch (Exception e) { + return false; + } + }, "Failed to delete index file"); + // verify no index files on disk assertFalse(getIndexFileFromRemoteCacheDir(cache, LogFileUtils.INDEX_FILE_SUFFIX).isPresent(), "Offset index file should not be present on disk at " + tpDir.toPath());