commit 7d3b4b42bd69d1a4e839faabff472d779b48dd31 Author: Dave Parfitt Date: Mon Dec 1 21:43:59 2014 -0500 fix for KAFKA-1803 diff --git a/core/src/main/scala/kafka/log/LogConfig.scala b/core/src/main/scala/kafka/log/LogConfig.scala index f2fbc55..862ff61 100644 --- a/core/src/main/scala/kafka/log/LogConfig.scala +++ b/core/src/main/scala/kafka/log/LogConfig.scala @@ -172,8 +172,8 @@ object LogConfig { .define(CleanupPolicyProp, STRING, if (Defaults.Compact) Compact else Delete, in(asList(Compact, Delete)), MEDIUM, CompactDoc) // we validate true/false explicitly to fail in case of typo - .define(UncleanLeaderElectionEnableProp, STRING, Defaults.UncleanLeaderElectionEnable.toString, - in(asList(true.toString, false.toString)), MEDIUM, UncleanLeaderElectionEnableDoc) + .define(UncleanLeaderElectionEnableProp, BOOLEAN, Defaults.UncleanLeaderElectionEnable, + null, MEDIUM, UncleanLeaderElectionEnableDoc) .define(MinInSyncReplicasProp, INT, Defaults.MinInSyncReplicas, atLeast(1), MEDIUM, MinInSyncReplicasDoc) } @@ -202,7 +202,7 @@ object LogConfig { deleteRetentionMs = parsed.get(DeleteRetentionMsProp).asInstanceOf[Long], minCleanableRatio = parsed.get(MinCleanableDirtyRatioProp).asInstanceOf[Double], compact = parsed.get(CleanupPolicyProp).asInstanceOf[String].toLowerCase != Delete, - uncleanLeaderElectionEnable = parsed.get(UncleanLeaderElectionEnableProp).asInstanceOf[String].toBoolean, + uncleanLeaderElectionEnable = parsed.get(UncleanLeaderElectionEnableProp).asInstanceOf[Boolean], minInSyncReplicas = parsed.get(MinInSyncReplicasProp).asInstanceOf[Int]) }