From 127f7d6ea5ac39f8fa678b417a2884b9fc2ed8f2 Mon Sep 17 00:00:00 2001 From: Sriharsha Chintalapani Date: Sat, 10 Jan 2015 12:14:33 -0800 Subject: [PATCH] KAFKA-1757. Can not delete Topic index on Windows. --- core/src/main/scala/kafka/log/OffsetIndex.scala | 2 ++ 1 file changed, 2 insertions(+) diff --git a/core/src/main/scala/kafka/log/OffsetIndex.scala b/core/src/main/scala/kafka/log/OffsetIndex.scala index 1c4c7bd..ca82c04 100644 --- a/core/src/main/scala/kafka/log/OffsetIndex.scala +++ b/core/src/main/scala/kafka/log/OffsetIndex.scala @@ -318,6 +318,8 @@ class OffsetIndex(@volatile var file: File, val baseOffset: Long, val maxIndexSi */ def delete(): Boolean = { info("Deleting index " + this.file.getAbsolutePath) + if(Os.isWindows) + Utils.swallow(forceUnmap(this.mmap)) this.file.delete() } -- 1.9.3 (Apple Git-50)