KAFKA-2002: Mx4JLoader doesn't disable when kafka_mx4jenable=false.

This commit is contained in:
Yaguo Zhou 2015-04-04 15:21:51 -07:00 committed by Jay Kreps
parent 70e5c92e21
commit a686a67f60
1 changed files with 1 additions and 1 deletions

View File

@ -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 {