[SO] Remove DMaap Dependency in SO-bpmn-infra

[so.git] / common / src / main / java / org / onap / so / client / kafka / KafkaClient.java

diff --git a/common/src/main/java/org/onap/so/client/kafka/KafkaClient.java b/common/src/main/java/org/onap/so/client/kafka/KafkaClient.java
new file mode 100644 (file)
index 0000000..2c69525
--- /dev/null
+++ b/common/src/main/java/org/onap/so/client/kafka/KafkaClient.java
@@ -0,0 +1,21 @@
+package org.onap.so.client.kafka;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.core.io.ClassPathResource;
+import org.springframework.core.io.Resource;
+import java.io.IOException;
+import java.util.Properties;
+
+public class KafkaClient {
+    protected static Logger logger = LoggerFactory.getLogger(KafkaClient.class);
+    protected final Properties properties;
+
+    public KafkaClient(String filepath) throws IOException {
+        Resource resource = new ClassPathResource(filepath);
+        this.properties = new Properties();
+        properties.load(resource.getInputStream());
+
+    }
+
+}