AbstractConfig.java

public class AbstractConfig {
public AbstractConfig(ConfigDef definition, Map<?, ?> originals, boolean doLog) {
// 这里的origin就是producer在new的时候传入的props键值对
this.originals = (Map<String, ?>) originals;
// 应该是合并了自定义的props和producer缺省的配置
this.values = definition.parse(this.originals);
}

// AbstractConfig的核心方法，通过反射实例化originals字段中指定的类
public <T> T getConfiguredInstance(String key, Class<T> t) {
    // 从合并总配置项values里获取指定key约定的class类型
    // 例如key = partitioner.class, value = DefaultPartitioner.class
    Class<?> c = getClass(key);
    // 无论是否Configurable对象，都是统一通过无参构造函数实例化
    Object o = Utils.newInstance(c);
    if (o instanceof Configurable)
        // Configurable接口的实例，单独调用约定的configure方法，传入originals键值对做初始化工作
        // 就可以在统一无参构造实例化的前提下，通过键值对入参达到个性化初始化
        ((Configurable) o).configure(this.originals);
    // 这里的t是显示要求的范式类型T,最后会做强转返回
    return t.cast(o);
}

}