X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdmf%2Fmr%2Fresources%2FCambriaOutboundEventStream.java;fp=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdmf%2Fmr%2Fresources%2FCambriaOutboundEventStream.java;h=dfe5e3bc8e302b49711b23c1b727b40e1076e5d0;hb=076def9c700fdd6472c62c837b0ce067bab55a4c;hp=2f7f1db6c2fabfe672610741ca98070b4c86c87c;hpb=b3354b73e2de1579adb346ff1f10966585f3aeab;p=dmaap%2Fmessagerouter%2Fmsgrtr.git diff --git a/src/main/java/org/onap/dmaap/dmf/mr/resources/CambriaOutboundEventStream.java b/src/main/java/org/onap/dmaap/dmf/mr/resources/CambriaOutboundEventStream.java index 2f7f1db..dfe5e3b 100644 --- a/src/main/java/org/onap/dmaap/dmf/mr/resources/CambriaOutboundEventStream.java +++ b/src/main/java/org/onap/dmaap/dmf/mr/resources/CambriaOutboundEventStream.java @@ -27,13 +27,8 @@ import java.util.ArrayList; import java.util.Date; import javax.servlet.http.HttpServletRequest; -import javax.servlet.http.HttpServletResponse; - -import org.apache.kafka.clients.consumer.ConsumerRecord; -import org.apache.kafka.clients.consumer.ConsumerRecords; import org.json.JSONException; import org.json.JSONObject; -import org.json.JSONTokener; import com.att.ajsc.filemonitor.AJSCPropertiesMap; import org.onap.dmaap.dmf.mr.CambriaApiException;