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