From b32effcaf5684d5e2f338a4537b71a2375c534e5 Mon Sep 17 00:00:00 2001 From: sunil unnava Date: Tue, 14 Aug 2018 09:34:46 -0400 Subject: update the testcases after the kafka 11 changes Issue-ID: DMAAP-526 Change-Id: I477a8ee05fb3cdd76af726b6ca0d1a69aa9eef93 Signed-off-by: sunil unnava --- .../cambria/resources/streamReaders/CambriaRawStreamReaderTest.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'src/test/java/com/att/nsa/cambria/resources/streamReaders/CambriaRawStreamReaderTest.java') diff --git a/src/test/java/com/att/nsa/cambria/resources/streamReaders/CambriaRawStreamReaderTest.java b/src/test/java/com/att/nsa/cambria/resources/streamReaders/CambriaRawStreamReaderTest.java index 1a51712..a5a3aac 100644 --- a/src/test/java/com/att/nsa/cambria/resources/streamReaders/CambriaRawStreamReaderTest.java +++ b/src/test/java/com/att/nsa/cambria/resources/streamReaders/CambriaRawStreamReaderTest.java @@ -24,13 +24,15 @@ import static org.junit.Assert.*; import java.io.IOException; import java.io.InputStream; -import com.att.nsa.cambria.backends.Publisher.message; +import com.att.dmf.mr.backends.Publisher.message; +import com.att.dmf.mr.resources.streamReaders.CambriaRawStreamReader; + import org.apache.commons.io.IOUtils; import org.junit.After; import org.junit.Before; import org.junit.Test; -import com.att.nsa.cambria.CambriaApiException; +import com.att.dmf.mr.CambriaApiException; public class CambriaRawStreamReaderTest { -- cgit 1.2.3-korg