From d03996018ffd7e3202f8b8094788604b855f3746 Mon Sep 17 00:00:00 2001 From: xueqiang wang Date: Thu, 9 Oct 2014 15:15:00 +0800 Subject: [PATCH] truncate off trailing zeros on broker restart if broker is gracefully stopped. --- kafka/kafka-0.8.1.1/core/src/main/scala/kafka/log/Log.scala | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/kafka/kafka-0.8.1.1/core/src/main/scala/kafka/log/Log.scala b/kafka/kafka-0.8.1.1/core/src/main/scala/kafka/log/Log.scala index 6f3baa7..f990032 100644 --- a/kafka/kafka-0.8.1.1/core/src/main/scala/kafka/log/Log.scala +++ b/kafka/kafka-0.8.1.1/core/src/main/scala/kafka/log/Log.scala @@ -172,6 +172,10 @@ class Log(val dir: File, } } else { recoverLog() + // If broker is gracefully stopped, the active segment should be truncated off on broker restart + if (Os.isWindows) { + activeSegment.recover(config.maxMessageSize) + } // reset the index size of the currently active log segment to allow more entries activeSegment.index.resize(config.maxIndexSize) } -- 1.9.4.msysgit.0