package com.core;

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) {
		
		
		
		
		
	}
	
	
	
	
	
}

@@ -12,16 +12,106 @@
 .core;%0A%0A
+import java.io.FileInputStream;%0Aimport java.io.InputStream;%0Aimport java.util.Properties;%0A%0A
 public c
@@ -710,19 +710,107 @@
 le) %7B%0A%09%09
-%0A%09%09
+prop = new Properties();%0A%09%09InputStream is = new FileInputStream(confFile);%0A%09%09prop.load(is);
 %0A%09%09%0A%09%09%0A%09

Update KafkaParams.java