diff --git a/external/storm-kafka/src/test/org/apache/storm/kafka/KafkaTestBroker.java b/external/storm-kafka/src/test/org/apache/storm/kafka/KafkaTestBroker.java
index e2fb60f5a03..8483aabe7bf 100644
--- a/external/storm-kafka/src/test/org/apache/storm/kafka/KafkaTestBroker.java
+++ b/external/storm-kafka/src/test/org/apache/storm/kafka/KafkaTestBroker.java
@@ -67,7 +67,7 @@ private kafka.server.KafkaConfig buildKafkaConfig(String zookeeperConnectionStri
         p.setProperty("broker.id", "0");
         p.setProperty("port", "" + port);
         p.setProperty("log.dirs", logDir.getAbsolutePath());
-        return new KafkaConfig(p);
+        return KafkaConfig.fromProps(p);
     }
 
     public String getBrokerConnectionString() {