From 3eafa2abe587d666491dc20c8088e3b6f00c924e Mon Sep 17 00:00:00 2001
From: Alexey Ozeritsky <aozeritsky@yandex-team.ru>
Date: Fri, 21 Mar 2014 14:57:16 +0400
Subject: [PATCH]  * speedup

---
 core/src/main/scala/kafka/log/Log.scala | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/core/src/main/scala/kafka/log/Log.scala b/core/src/main/scala/kafka/log/Log.scala
index b3ab522..5f0c5da 100644
--- a/core/src/main/scala/kafka/log/Log.scala
+++ b/core/src/main/scala/kafka/log/Log.scala
@@ -161,9 +161,11 @@ class Log(val dir: File,
   
   private def recoverLog() {
     // if we have the clean shutdown marker, skip recovery
-    if(hasCleanShutdownFile) {
+    if (hasCleanShutdownFile) {
       this.recoveryPoint = activeSegment.nextOffset
       return
+    } else {
+      this.recoveryPoint = activeSegment.baseOffset
     }
 
     // okay we need to actually recovery this log
-- 
1.8.5.5