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

   1 package org.onap.so.client.kafka;
   2
   3 import org.slf4j.Logger;
   4 import org.slf4j.LoggerFactory;
   5 import org.springframework.core.io.ClassPathResource;
   6 import org.springframework.core.io.Resource;
   7 import java.io.IOException;
   8 import java.util.Properties;
   9
  10 public class KafkaClient {
  11     protected static Logger logger = LoggerFactory.getLogger(KafkaClient.class);
  12     protected final Properties properties;
  13
  14     public KafkaClient(String filepath) throws IOException {
  15         Resource resource = new ClassPathResource(filepath);
  16         this.properties = new Properties();
  17         properties.load(resource.getInputStream());
  18
  19     }
  20
  21 }