kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jkr...@apache.org
Subject [2/2] kafka git commit: KAFKA-2002: Mx4JLoader doesn't disable when kafka_mx4jenable=false.
Date Sat, 04 Apr 2015 22:32:12 GMT
KAFKA-2002: Mx4JLoader doesn't disable when kafka_mx4jenable=false.


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/a686a67f
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/a686a67f
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/a686a67f

Branch: refs/heads/trunk
Commit: a686a67f60beb42eb3d4942508fb15b636e5100d
Parents: 70e5c92
Author: Yaguo Zhou <zhouyaguo@gmail.com>
Authored: Sat Apr 4 15:21:51 2015 -0700
Committer: Jay Kreps <jay.kreps@gmail.com>
Committed: Sat Apr 4 15:27:41 2015 -0700

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


http://git-wip-us.apache.org/repos/asf/kafka/blob/a686a67f/core/src/main/scala/kafka/utils/Mx4jLoader.scala
----------------------------------------------------------------------
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 {


Mime
View raw message