Fix for Kafka Consumer is not safe error

Issue-ID: DMAAP-896
Change-Id: If3e93533b1d6f37ef7b2685c83e4785d62257ffa
Signed-off-by: sunil unnava <sunil.unnava@att.com>

2 files changed, 26 insertions, 22 deletions

diff --git a/pom.xml b/pom.xml
index ea8f069..5de6742 100644
--- a/pom.xml
+++ b/pom.xml
@@ -262,7 +262,7 @@
 		<testRouteOffer>workstation</testRouteOffer>
 		<testEnv>DEV</testEnv>
 		<!-- <dmaapImg>${project.version}</dmaapImg> -->
-		<dmaapImg>1.1.8</dmaapImg>
+		<dmaapImg>1.1.9</dmaapImg>
 		<camel.version>2.21.1</camel.version>
 		<sitePath>/content/sites/site/org/onap/dmaap/messagerouter/messageservice/${project.artifactId}/${project.version}</sitePath>
 		<skip.docker.build>true</skip.docker.build>
@@ -457,7 +457,7 @@
 		<dependency>
 			<groupId>org.onap.dmaap.messagerouter.msgrtr</groupId>
 			<artifactId>msgrtr</artifactId>
-			<version>1.1.13</version>
+			<version>1.1.14-SNAPSHOT</version>
 			<exclusions>
 				<exclusion>
 					<groupId>org.slf4j</groupId>
@@ -1337,6 +1337,29 @@
 							</execution>
 						</executions>
 					</plugin>
+					 <plugin>
+			<groupId>org.apache.maven.plugins</groupId>
+			<artifactId>maven-enforcer-plugin</artifactId>
+			<executions>
+				<execution>
+					<id>enforce-no-snapshots</id>
+					<goals>
+						<goal>enforce</goal>
+					</goals>
+					<configuration>
+						<rules>
+							<requireReleaseDeps>
+								<message>No Snapshots Allowed!</message>
+								<excludes>
+									<exclude>org.onap.dmaap.messagerouter.msgrtr:msgrtr</exclude>
+								</excludes>
+							</requireReleaseDeps>
+						</rules>
+						<fail>true</fail>
+					</configuration>
+				</execution>
+			</executions>
+		</plugin>
 				</plugins>
 				<pluginManagement>
 					<plugins>
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