diff --git a/metadata/src/main/java/org/apache/kafka/image/publisher/SnapshotEmitter.java b/metadata/src/main/java/org/apache/kafka/image/publisher/SnapshotEmitter.java index 398e3fdae8a..cb025823bf4 100644 --- a/metadata/src/main/java/org/apache/kafka/image/publisher/SnapshotEmitter.java +++ b/metadata/src/main/java/org/apache/kafka/image/publisher/SnapshotEmitter.java @@ -158,7 +158,6 @@ public class SnapshotEmitter implements SnapshotGenerator.Emitter { throw e; } finally { Utils.closeQuietly(writer, "RaftSnapshotWriter"); - Utils.closeQuietly(snapshotWriter.get(), "SnapshotWriter"); } } }