private void addAttrConfigs()

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);
            }
        });
    }