in rcomp-kafka/src/main/java/org/apache/karaf/rcomp/kafka/ConfigMapper.java [36:41]
public static Properties mapProducer(Dictionary<String, Object> conf) {
ConfigMapper mapper = new ConfigMapper(conf);
mapper.mapCommon();
mapper.mapProducer();
return mapper.config;
}