From 1e8f5bc7689030d5679cf96c28ffdd6cc2661ca3 Mon Sep 17 00:00:00 2001 From: Yaguo Zhou Date: Wed, 4 Mar 2015 22:45:42 +0800 Subject: [PATCH] does not work when kafka_mx4jenable is false --- core/src/main/scala/kafka/utils/Mx4jLoader.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/utils/Mx4jLoader.scala b/core/src/main/scala/kafka/utils/Mx4jLoader.scala index db9f20b..7417897 100644 --- a/core/src/main/scala/kafka/utils/Mx4jLoader.scala +++ b/core/src/main/scala/kafka/utils/Mx4jLoader.scala @@ -35,7 +35,7 @@ object Mx4jLoader extends Logging { def maybeLoad(): Boolean = { val props = new VerifiableProperties(System.getProperties()) if (props.getBoolean("kafka_mx4jenable", false)) - false + return false val address = props.getString("mx4jaddress", "0.0.0.0") val port = props.getInt("mx4jport", 8082) try { -- 1.9.3 (Apple Git-50)