package com.sitech.ismp.coll.centercoll;

import org.apache.log4j.Logger;

import java.util.HashMap;

/**
 * Created by diaodx on 2015/8/31.
 */
public class CollKafkaWithJMXFactor {
    private Logger logger = Logger.getLogger("COLL");
    private CollKafkaI coll = null;

    public CollKafkaI getCollInstance (HashMap<String, String> params){
        String version =  params.get("VERSION");
        if (version == null || version.equals("")) {
            logger.error("Cant't get Kafka version from coll params.");
            return null;
        }

        if (version.trim().equals("9")) {
            coll = new CollKafkaWithJMX();
        } else if (version.trim().equals("11")) {
            coll = new CollKafkaWithJMX211();
        } else {
            coll = new CollKafkaWithJMX();
        }
        return  coll;
    }
}