private void addTopicConfigs()

in src/main/java/com/amazonaws/mskdatagen/core/Context.java [150:182]
31 lines of code
6 McCabe index (conditional complexity)

    private void addTopicConfigs(List<Config> configs) {
        RetainedConfig retainedConfig
                = (RetainedConfig) getConfig(ConfigType.RETAINED_CONFIG, ConfigType.TOPIC_CONFIG.getConfigGroup());

        configs.forEach(config -> {
            if (config.getKind() == Kind.TOPIC) {
                TopicConfigs topicConfigs
                        = (TopicConfigs) getConfig(ConfigType.TOPIC_CONFIG, config.getTopic());

                Optional.ofNullable(config.getConfigs()).ifPresent(t -> {
                    String join = String.join(".", t);
                    switch (join) {
                        case "throttle.ms":
                            topicConfigs.setThrottleMs(Long.parseLong(config.getValue()));
                            break;
                        case "history.records.max":
                            topicConfigs.setHistoryRecordsMax(Long.parseLong(config.getValue()));
                            break;
                        case "tombstone.rate":
                            topicConfigs.setTombstoneRate(Double.parseDouble(config.getValue()));
                            break;
                        case "records.exactly":
                            topicConfigs.setRecordsExactly(Long.parseLong(config.getValue()));
                            break;
                        default:
                            String message = String.format("Unrecognized topic configuration: %s", config.getOriginalKey());
                            throw new IllegalArgumentException(message);
                    }
                });
                retainedConfig.addOriginalConfigs(config);
            }
        });
    }