update the testcases after the kafka 11 changes

[dmaap/messagerouter/msgrtr.git] / src / test / java / com / att / nsa / cambria / metrics / publisher / DMaaPCambriaClientFactoryTest.java

diff --git a/src/test/java/com/att/nsa/cambria/metrics/publisher/DMaaPCambriaClientFactoryTest.java b/src/test/java/com/att/nsa/cambria/metrics/publisher/DMaaPCambriaClientFactoryTest.java
index c2b3391..5916a18 100644 (file)
--- a/src/test/java/com/att/nsa/cambria/metrics/publisher/DMaaPCambriaClientFactoryTest.java
+++ b/src/test/java/com/att/nsa/cambria/metrics/publisher/DMaaPCambriaClientFactoryTest.java
@@ -29,10 +29,10 @@ import org.junit.After;
 import org.junit.Before;\r
 import org.junit.Test;\r
 \r
-import com.att.nsa.cambria.listener.DME2EndPointLoader;\r
-import com.att.nsa.cambria.metrics.publisher.CambriaConsumer;\r
-import com.att.nsa.cambria.metrics.publisher.CambriaPublisherUtility;\r
-import com.att.nsa.cambria.metrics.publisher.DMaaPCambriaClientFactory;\r
+import com.att.dmf.mr.listener.DME2EndPointLoader;\r
+import com.att.dmf.mr.metrics.publisher.CambriaConsumer;\r
+import com.att.dmf.mr.metrics.publisher.CambriaPublisherUtility;\r
+import com.att.dmf.mr.metrics.publisher.DMaaPCambriaClientFactory;\r
 \r
 public class DMaaPCambriaClientFactoryTest {\r
        \r