X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=src%2Fmain%2Fjava%2Fcom%2Fatt%2Fdmf%2Fmr%2Futils%2FUtils.java;h=c2b8b88c5c87f18942df3b50afefbebdcb03f6f6;hb=3c077fdac44a644167b246ed4e0377603f54804d;hp=70691cfceadeec3584ef6b5f038fb02f86c3023f;hpb=7183a01048c01c4810f2096408406cd0dbf85753;p=dmaap%2Fmessagerouter%2Fmsgrtr.git

diff --git a/src/main/java/com/att/dmf/mr/utils/Utils.java b/src/main/java/com/att/dmf/mr/utils/Utils.java
index 70691cf..c2b8b88 100644
--- a/src/main/java/com/att/dmf/mr/utils/Utils.java
+++ b/src/main/java/com/att/dmf/mr/utils/Utils.java
@@ -21,16 +21,22 @@
  *******************************************************************************/
 package com.att.dmf.mr.utils;
 
+import java.io.IOException;
+import java.io.InputStream;
 import java.text.DecimalFormat;
 import java.text.SimpleDateFormat;
 import java.util.Date;
 import java.util.Enumeration;
 import java.util.LinkedList;
 import java.util.List;
+import java.util.Properties;
 
 import javax.servlet.http.HttpServletRequest;
 
+import com.att.dmf.mr.backends.kafka.KafkaPublisher;
 import com.att.dmf.mr.beans.DMaaPContext;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
 /**
  * This is an utility class for various operations for formatting
  * @author nilanjana.maity
@@ -41,6 +47,7 @@ public class Utils {
 	private static final String DATE_FORMAT = "dd-MM-yyyy::hh:mm:ss:SSS";
 	public static final String CAMBRIA_AUTH_HEADER = "X-CambriaAuth";
 	private static final String BATCH_ID_FORMAT = "000000";
+	private static final EELFLogger log = EELFManager.getInstance().getLogger(Utils.class);
 
 	private Utils() {
 		super();
@@ -142,4 +149,17 @@ public class Utils {
 	    }
 	    return list;
 	  }
+	  
+	  public static String getKafkaproperty(){
+		  InputStream input = new Utils().getClass().getResourceAsStream("/kafka.properties");
+			Properties props = new Properties();
+			try {
+				props.load(input);
+			} catch (IOException e) {
+				log.error("failed to read kafka.properties");
+			}
+			return props.getProperty("key");
+			
+		  
+	  }
 }