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