DMaaPKafkaConsumerFactory.java 文件源码

private ConsumerConfig createConsumerConfig(String groupId,
        String consumerId) {
    final Properties props = new Properties();
    props.put("zookeeper.connect", fZooKeeper);
    props.put("group.id", groupId);
    props.put("consumer.id", consumerId);
    //props.put("auto.commit.enable", "false");
    // additional settings: start with our defaults, then pull in configured
    // overrides
    props.putAll(KafkaInternalDefaults);
    for (String key : KafkaConsumerKeys) {
        transferSettingIfProvided(props, key, "kafka");
    }

    return new ConsumerConfig(props);
}