KafkaConsumer.java 文件源码

public KafkaConsumer(final String topic, final String configFile) {
    this.topic = topic;
    Properties props = null;
    try {

        FileReader reader = new FileReader(configFile);

        props = new Properties();

        props.load(reader);

        config = new ConsumerConfig(props);

        //in.close();
    } catch (IOException e) {
        e.printStackTrace();
    }
}