package com.core;

import java.io.FileInputStream;
import java.io.InputStream;
import java.util.Properties;

public class KafkaParams {

	public static final String BROKER_LIST = "metadata.broker.list";
	public static final String SERIALIZER = "serializer.class";
	public static final String REQUIRED_ACKS = "request.required.acks";
	public static final String KAFKA_TOPIC = "kafka.topic";

	public static final String BROKER_LIST_VALUE = "172.17.42.1:49154";
	public static final String SERIALIZER_VALUE = "kafka.serializer.StringEncoder";
	public static final String REQUIRED_ACKS_VALUE = "request.required.acks";
	public static final String KAFKA_TOPIC_VALUE = "tweets";
	
	public KafkaParams(String confFile) {
		prop = new Properties();
		InputStream is = new FileInputStream(confFile);
		prop.load(is);
		
		
		
	}
	
	
	
	
	
}

@@ -134,37 +134,24 @@
  %7B%0A%0A%09public 
-static final 
 String BROKE
@@ -187,37 +187,24 @@
 t%22;%0A%09public 
-static final 
 String SERIA
@@ -235,37 +235,24 @@
 s%22;%0A%09public 
-static final 
 String REQUI
@@ -291,37 +291,24 @@
 s%22;%0A%09public 
-static final 
 String KAFKA
@@ -331,25 +331,24 @@
 topic%22;%0A
-%0A
 %09public 
 static f
@@ -335,37 +335,24 @@
 c%22;%0A%09public 
-static final 
 String BROKE
@@ -391,37 +391,24 @@
 4%22;%0A%09public 
-static final 
 String SERIA
@@ -459,37 +459,24 @@
 r%22;%0A%09public 
-static final 
 String REQUI
@@ -529,21 +529,8 @@
 lic 
-static final 
 Stri
@@ -713,16 +713,90 @@
 %0A%09%7D%0A%09%0A%09%0A
-
 %09
+public String getString(String key) %7B%0A%09%09return prop.getProperty(key);%0A%09%7D%0A%7D
 %0A%09%0A%09%0A%7D%0A

Update KafkaParams.java