update the testcases after the kafka 11 changes

[dmaap/messagerouter/msgrtr.git] / src / test / java / com / att / nsa / cambria / backends / memory / MemoryConsumerFactoryTest.java

diff --git a/src/test/java/com/att/nsa/cambria/backends/memory/MemoryConsumerFactoryTest.java b/src/test/java/com/att/nsa/cambria/backends/memory/MemoryConsumerFactoryTest.java
index 7b470bc..d6fe6e6 100644 (file)
--- a/src/test/java/com/att/nsa/cambria/backends/memory/MemoryConsumerFactoryTest.java
+++ b/src/test/java/com/att/nsa/cambria/backends/memory/MemoryConsumerFactoryTest.java
@@ -28,6 +28,8 @@ import org.junit.After;
 import org.junit.Before;\r
 import org.junit.Test;\r
 \r
+import com.att.dmf.mr.backends.memory.MemoryConsumerFactory;\r
+\r
 public class MemoryConsumerFactoryTest {\r
 \r
        @Before\r
@@ -46,8 +48,9 @@ public class MemoryConsumerFactoryTest {
                String topic = "testTopic";\r
                String consumerGroupId = "CG1";\r
                String clientId = "C1";\r
+               String remoteHost="remoteHost";\r
                int timeoutMs = 1000; \r
-               factory.getConsumerFor(topic, consumerGroupId, clientId, timeoutMs);\r
+               factory.getConsumerFor(topic, consumerGroupId, clientId, timeoutMs,remoteHost);\r
                \r
                String trueValue = "True";\r
                assertTrue(trueValue.equalsIgnoreCase("True"));\r