in src/main/java/com/amazonaws/mskdatagen/core/Context.java [101:123]
private void addAttrConfigs(List<Config> configs) {
RetainedConfig retainedConfig
= (RetainedConfig) getConfig(ConfigType.RETAINED_CONFIG, ConfigType.ATTR_CONFIG.getConfigGroup());
configs.forEach(config -> {
if (config.getKind() == Kind.ATTRIBUTE_COMPLEX || config.getKind() == Kind.ATTRIBUTE_PRIMITIVE) {
AttrConfigs attrConfigs = (AttrConfigs) getConfig(ConfigType.ATTR_CONFIG, config.getTopic());
if ("key".equals(config.getNs())) {
Map<String, AttrConfig> key = attrConfigs.getNsMap().getKey();
AttrConfig attrConfig = key.computeIfAbsent(config.getAttr(), t -> new AttrConfig());
addAttrConfig(config, attrConfig);
} else if ("value".equals(config.getNs())) {
Map<String, AttrConfig> value = attrConfigs.getNsMap().getValue();
AttrConfig attrConfig = value.computeIfAbsent(config.getAttr(), t -> new AttrConfig());
addAttrConfig(config, attrConfig);
}
retainedConfig.addOriginalConfigs(config);
}
});
}