package com.sitech.base;

import java.util.ResourceBundle;

public class KafkaConfigs {
	public static final String serializer;
	public static final String metadataList;
	public static final String partitioner;
	public static final String required;


	static {
		ResourceBundle mqConfig = ResourceBundle.getBundle("kafka");
		serializer = mqConfig.getString("serializer.class");
		metadataList = mqConfig.getString("metadata.broker.list");
		partitioner = mqConfig.getString("partitioner.class");
		required = mqConfig.getString("request.required.acks");
	}
}