summaryrefslogtreecommitdiffstats
path: root/src/main/java/org
diff options
context:
space:
mode:
authorsunil unnava <sunil.unnava@att.com>2018-12-06 06:35:09 -0500
committersunil unnava <sunil.unnava@att.com>2018-12-06 06:35:30 -0500
commit4ee18157bfcf53e256be4c6bb928c658b027cab5 (patch)
tree138c4d3a2a483f3df35f2164007c9c7e424ed6b5 /src/main/java/org
parent2b80d1a99615392a791fa15f04085601f13fbaba (diff)
Fix for Kafka Consumer is not safe error
Issue-ID: DMAAP-896 Change-Id: If3e93533b1d6f37ef7b2685c83e4785d62257ffa Signed-off-by: sunil unnava <sunil.unnava@att.com>
Diffstat (limited to 'src/main/java/org')
-rw-r--r--src/main/java/org/onap/dmaap/service/EventsRestService.java21
1 files changed, 1 insertions, 20 deletions
diff --git a/src/main/java/org/onap/dmaap/service/EventsRestService.java b/src/main/java/org/onap/dmaap/service/EventsRestService.java
index b4aee10..d3abd6b 100644
--- a/src/main/java/org/onap/dmaap/service/EventsRestService.java
+++ b/src/main/java/org/onap/dmaap/service/EventsRestService.java
@@ -21,6 +21,7 @@
*******************************************************************************/
package org.onap.dmaap.service;
+import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.Date;
@@ -97,7 +98,6 @@ public class EventsRestService {
@Autowired
private DMaaPErrorMessages errorMessages;
- private boolean isOffsetTopicCreated=false;
/**
* This method is used to consume messages.Taking three parameter
@@ -257,9 +257,6 @@ public class EventsRestService {
@QueryParam("partitionKey") String partitionKey) throws CambriaApiException {
log.info("Publishing message to topic " + topic);
- if(!isOffsetTopicCreated){
- preCreateOffsetTopic(msg);
- }
try {
eventsService.pushEvents(getDmaapContext(), topic, msg, partitionKey, null);
}
@@ -322,10 +319,6 @@ public class EventsRestService {
try {
- if(!isOffsetTopicCreated){
- preCreateOffsetTopic(request.getInputStream());
- }
-
eventsService.pushEvents(getDmaapContext(), topic, request.getInputStream(),
partitionKey,
Utils.getFormattedDate(new Date()));
@@ -386,17 +379,5 @@ public class EventsRestService {
return dmaapContext;
}
- private void preCreateOffsetTopic(InputStream msg) {
-
- try {
- eventsService.pushEvents(getDmaapContext(), "DUMMY_TOPIC", msg, null, null);
- eventsService.getEvents(getDmaapContext(), "DUMMY_TOPIC", "CG1", "C1");
- isOffsetTopicCreated = true;
- } catch (CambriaApiException | ConfigDbException | AccessDeniedException | TopicExistsException | IOException
- | missingReqdSetting | UnavailableException e) {
- log.error("Error while creating the dummy topic", e);
- }
-
- }
} \ No newline at end of file