From 68bdcc53d5ea88e6ee84bcea3a0aa5fcfe0979d5 Mon Sep 17 00:00:00 2001
From: Sriharsha Chintalapani <harsha@hortonworks.com>
Date: Wed, 27 Apr 2016 19:50:28 -0700
Subject: [PATCH] STORM-1736. Change KafkaTestBroker.buildKafkaConfig to new
 KafkaConfig api.

---
 .../src/test/org/apache/storm/kafka/KafkaTestBroker.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 e2fb60f5a0..8483aabe7b 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() {