private void fillGeneratorByStrategy()

in src/main/java/com/amazonaws/mskdatagen/core/Context.java [225:244]


    private void fillGeneratorByStrategy(Generator.GeneratorBuilder generatorBuilder, Config config) {
        if ("with".equals(config.getGenerator())) {
            generatorBuilder.setStrategy(Strategy.ISOLATED);
            generatorBuilder.setTopic(config.getTopic());
            generatorBuilder.setNs(config.getNs());
            generatorBuilder.setExpression(config.getValue());
            fillAttr(config, generatorBuilder);
        } else if ("matching".equals(config.getGenerator())) {
            generatorBuilder.setStrategy(Strategy.DEPENDENT);
            String[] values = config.getValue().split("\\.");
            String topic = values[0];
            String ns = values[1];
            generatorBuilder.setTopic(topic);
            generatorBuilder.setNs(ns);
            if (values.length > 2) {
                String[] attrs = values[2].split("->");
                generatorBuilder.setAttr(Arrays.asList(attrs));
            }
        }
    }