From c24e96b543fd9cb6dd8d2a56b9c5320e1c0daa36 Mon Sep 17 00:00:00 2001
From: Sriram Subramanian <srsubram@srsubram-ld.linkedin.biz>
Date: Fri, 15 Feb 2013 16:15:23 -0800
Subject: [PATCH] Ensure checkpoint highwater mark thread is actually created

---
 .../main/scala/kafka/server/ReplicaManager.scala   |    2 ++
 1 files changed, 2 insertions(+), 0 deletions(-)

diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala b/core/src/main/scala/kafka/server/ReplicaManager.scala
index 064af6b..93e2e67 100644
--- a/core/src/main/scala/kafka/server/ReplicaManager.scala
+++ b/core/src/main/scala/kafka/server/ReplicaManager.scala
@@ -92,6 +92,8 @@ class ReplicaManager(val config: KafkaConfig,
   def startup() {
     // start ISR expiration thread
     kafkaScheduler.scheduleWithRate(maybeShrinkIsr, "isr-expiration-thread-", 0, config.replicaLagTimeMaxMs)
+    // start highwatermark checkpoint thread
+    startHighWaterMarksCheckPointThread()
   }
 
   def stopReplica(topic: String, partitionId: Int, deletePartition: Boolean): Short  = {
-- 
1.7.1