Make initZk protected

From: Christian Kampka <christian.kampka@freiheit.com>


---
 core/src/main/scala/kafka/server/KafkaServer.scala |    2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/src/main/scala/kafka/server/KafkaServer.scala b/core/src/main/scala/kafka/server/KafkaServer.scala
index dddef93..513a41b 100644
--- a/core/src/main/scala/kafka/server/KafkaServer.scala
+++ b/core/src/main/scala/kafka/server/KafkaServer.scala
@@ -178,7 +178,7 @@ class KafkaServer(val config: KafkaConfig, time: Time = SystemTime) extends Logg
     }
   }
 
-  private def initZk(): ZkClient = {
+  protected def initZk(): ZkClient = {
     info("Connecting to zookeeper on " + config.zkConnect)
 
     val chroot = {