From f30ece617d3f7755eb3aaef00c7b02a0b669068d Mon Sep 17 00:00:00 2001 From: Dave Parfitt Date: Mon, 1 Dec 2014 21:43:59 -0500 Subject: [PATCH] fix for KAFKA-1803 --- core/src/main/scala/kafka/log/LogConfig.scala | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/core/src/main/scala/kafka/log/LogConfig.scala b/core/src/main/scala/kafka/log/LogConfig.scala index f2fbc55..ca7a99e 100644 --- a/core/src/main/scala/kafka/log/LogConfig.scala +++ b/core/src/main/scala/kafka/log/LogConfig.scala @@ -171,9 +171,8 @@ object LogConfig { MinCleanableRatioDoc) .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, + MEDIUM, UncleanLeaderElectionEnableDoc) .define(MinInSyncReplicasProp, INT, Defaults.MinInSyncReplicas, atLeast(1), MEDIUM, MinInSyncReplicasDoc) } @@ -202,7 +201,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]) } -- 1.9.3 (Apple Git-50)