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";
}

@@ -577,10 +577,79 @@
 weets%22;%0A
+%09%0A%09public KafkaParams(String confFile) %7B%0A%09%09%0A%09%09%0A%09%09%0A%09%09%0A%09%09%0A%09%7D%0A%09%0A%09%0A%09%0A%09%0A%09%0A
 %7D%0A

Update KafkaParams.java