From 54508d3e0ff36db30e5be37ccda5f6886ce9a2d7 Mon Sep 17 00:00:00 2001
From: glorage <zeadom@qq.com>
Date: Tue, 11 Mar 2014 11:28:43 +0800
Subject: [PATCH] Update LogManager.scala

Make sure newer segments would not be deleted
---
 core/src/main/scala/kafka/log/LogManager.scala | 1 +
 1 file changed, 1 insertion(+)

diff --git a/core/src/main/scala/kafka/log/LogManager.scala b/core/src/main/scala/kafka/log/LogManager.scala
index bcd2bb7cb3152..8bd0428eeab94 100644
--- a/core/src/main/scala/kafka/log/LogManager.scala
+++ b/core/src/main/scala/kafka/log/LogManager.scala
@@ -338,6 +338,7 @@ class LogManager(val logDirs: Array[File],
         diff -= segment.size
         true
       } else {
+        diff = 0
         false
       }
     }