test fixed

Netflix · Nov 11, 2014 · 0ad5bdd · 0ad5bdd
1 parent 8949677
commit 0ad5bdd
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/suro-kafka-producer/src/test/java/com/netflix/suro/sink/kafka/TestKafkaSink.java b/suro-kafka-producer/src/test/java/com/netflix/suro/sink/kafka/TestKafkaSink.java
@@ -255,7 +255,7 @@ public void testCheckPause() throws IOException, InterruptedException {
         String description = "{\n" +
                 "    \"type\": \"kafka\",\n" +
                 "    \"client.id\": \"kafkasink\",\n" +
-                "    \"bootstrap.servers\": \"localhost:2200,localhost:2201\",\n" +
+                "    \"bootstrap.servers\": \"" + kafkaServer.getBrokerListStr() + "\",\n" +
                 "    \"acks\": 1,\n" +
                 "    \"buffer.memory\": 1000,\n" +
                 "    \"batch.size\": 1000\n" +
@@ -297,7 +297,7 @@ public void testBlockingOnBufferFull() throws Throwable {
         String description = "{\n" +
                 "    \"type\": \"kafka\",\n" +
                 "    \"client.id\": \"kafkasink\",\n" +
-                "    \"bootstrap.servers\": \"localhost:2200,localhost:2201\",\n" +
+                "    \"bootstrap.servers\": \"" + kafkaServer.getBrokerListStr() + "\",\n" +
                 "    \"acks\": 1,\n" +
                 "    \"block.on.buffer.full\": true,\n" +
                 "    \"buffer.memory\": 1000,\n" +