diff --git a/core/src/main/scala/kafka/raft/KafkaMetadataLog.scala b/core/src/main/scala/kafka/raft/KafkaMetadataLog.scala index 5ebade240d77a..6ac39b7f6cbb5 100644 --- a/core/src/main/scala/kafka/raft/KafkaMetadataLog.scala +++ b/core/src/main/scala/kafka/raft/KafkaMetadataLog.scala @@ -346,7 +346,7 @@ final class KafkaMetadataLog private ( if (expiredSnapshots.nonEmpty) { scheduler.schedule( "delete-snapshot-files", - KafkaMetadataLog.deleteSnapshotFiles(log.dir.toPath, expiredSnapshots), + KafkaMetadataLog.deleteSnapshotFiles(log.dir.toPath, expiredSnapshots, this), fileDeleteDelayMs ) } @@ -443,11 +443,12 @@ object KafkaMetadataLog { private def deleteSnapshotFiles( logDir: Path, - expiredSnapshots: mutable.TreeMap[OffsetAndEpoch, Option[FileRawSnapshotReader]] + expiredSnapshots: mutable.TreeMap[OffsetAndEpoch, Option[FileRawSnapshotReader]], + logging: Logging ): () => Unit = () => { expiredSnapshots.foreach { case (snapshotId, snapshotReader) => snapshotReader.foreach { reader => - CoreUtils.swallow(reader.close(), this) + CoreUtils.swallow(reader.close(), logging) } Snapshots.deleteIfExists(logDir, snapshotId) } diff --git a/raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotReader.java b/raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotReader.java index 59d3c9cc628c6..48adea97ccacd 100644 --- a/raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotReader.java +++ b/raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotReader.java @@ -63,7 +63,7 @@ public void close() { String.format( "Unable to close snapshot reader %s at %s", snapshotId, - fileRecords.file + fileRecords ), e );