@@ -0,0 +1,1523 @@
+package JNode;%0A%0Aimport com.ericsson.otp.erlang.OtpNode;%0A%0Aimport java.util.Properties;%0A%0A/**%0A * Created by wangchunye on 5/21/16.%0A */%0Apublic class MyConsumerConfig %7B%0A    private int numOfThreads = 1;%0A    private String topic = %22topic1%22;%0A    private String zookeeper = %22zk:2181%22;%0A    private String groupId = %22my_group_id%22;%0A    private String moduleName = %22module%22;%0A    private String nodeName = %22im_libs%22;%0A    private OtpNode myself = null;%0A%0A    public MyConsumerConfig(Properties prop, String module, OtpNode myself) %7B%0A        this.topic = prop.getProperty(%22kafka.%22 + module + %22.topic%22, topic);%0A        moduleName = prop.getProperty(%22kafka.%22 + module + %22.module_name%22, module);%0A        nodeName = prop.getProperty(%22kafka.%22 + module + %22.node_name%22, nodeName);%0A        zookeeper = prop.getProperty(%22kafka.%22 + module + %22.zookeeper%22,zookeeper);%0A        groupId = prop.getProperty(%22kafka.%22 + module + %22.group_id%22, groupId);%0A        numOfThreads = Integer.parseInt(prop.getProperty(%22kafka.%22 + module + %22.num_of_threads%22, %221%22));%0A        this.myself = myself;%0A    %7D%0A%0A    public int getNumOfThreads() %7B%0A        return numOfThreads;%0A    %7D%0A%0A    public String getTopic() %7B%0A        return topic;%0A    %7D%0A%0A    public String getZookeeper() %7B%0A        return zookeeper;%0A    %7D%0A%0A    public String getGroupId() %7B%0A        return groupId;%0A    %7D%0A%0A    public String getModuleName() %7B%0A        return moduleName;%0A    %7D%0A%0A    public String getNodeName() %7B%0A        return nodeName;%0A    %7D%0A%0A    public OtpNode getMyself() %7B%0A        return myself;%0A    %7D%0A%7D%0A%0A%0A

add it