diff --git a/core/src/main/scala/kafka/log/LogSegment.scala b/core/src/main/scala/kafka/log/LogSegment.scala
index ac96434..4c6e147 100644
--- a/core/src/main/scala/kafka/log/LogSegment.scala
+++ b/core/src/main/scala/kafka/log/LogSegment.scala
@@ -275,6 +275,7 @@ class LogSegment(val log: FileMessageSet,
    * @throws KafkaStorageException if the delete fails.
    */
   def delete() {
+    close()
     val deletedLog = log.delete()
     val deletedIndex = index.delete()
     if(!deletedLog && log.file.exists)