diff --git a/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerWrapperWithHarness.java b/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerWrapperWithHarness.java index e73ac31b16c8..70ce9190d81c 100644 --- a/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerWrapperWithHarness.java +++ b/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerWrapperWithHarness.java @@ -93,7 +93,7 @@ public long remoteLogSize(TopicIdPartition topicIdPartition, int leaderEpoch) th @Override public void close() throws IOException { - remoteLogMetadataManagerHarness.remoteLogMetadataManager().close(); + remoteLogMetadataManagerHarness.close(); } @Override